-producer:
- bootstrap-server: :9092
- client-id: DEV
- topic: test
- acks: -1
- batch-size: 16384
- linger-ms: 0
- compression-type: gzip
+sumup:
+ gateway:
+ topic: test
management:
endpoint:
shutdown:
enabled: true
info:
kafka:
- bootstrap-server: ${producer.bootstrap-server}
- client-id: ${producer.client-id}
- topic: ${producer.topic}
- acks: ${producer.acks}
- batch-size: ${producer.batch-size}
- linger-ms: ${producer.linger-ms}
- compression-type: ${producer.compression-type}
+ bootstrap-servers: ${spring.kafka.bootstrap-servers}
+ client-id: ${spring.kafka.client-id}
+ group-id: ${spring.kafka.consumer.group-id}
+ auto-offset-reset: ${spring.kafka.consumer.auto-offset-reset}
+ auto-commit-interval-ms: ${spring.kafka.consumer.properties.auto.commit.interval.ms}
+ topic: ${sumup.gateway.topic}
+ acks: ${spring.kafka.producer.acks}
+ batch-size: ${spring.kafka.producer.batch-size}
+ linger-ms: ${spring.kafka.producer.properties.linger.ms}
+ compression-type: ${spring.kafka.producer.compression-type}
+spring:
+ kafka:
+ bootstrap-servers: :9092
+ client-id: DEV
+ consumer:
+ auto-offset-reset: earliest
+ group-id: my-group
+ properties:
+ auto.commit.interval.ms: 5000
+ producer:
+ acks: -1
+ batch-size: 16384
+ compression-type: gzip
+ key-serializer: org.apache.kafka.common.serialization.StringSerializer
+ value-serializer: org.apache.kafka.common.serialization.IntegerSerializer
+ properties:
+ linger.ms: 0
+ delivery.timeout.ms: 20000 # 20 Sekunden
+ request.timeout.ms: 10000 # 10 Sekunden
+ template:
+ default-topic: test
logging:
level:
root: INFO
de.juplo: DEBUG
server:
- port: 8880
+ port: 8881