simple:
consumer:
- bootstrap-servers: ":9092"
- group-id: "my-group"
- client-id: "DEV"
topic: test
- auto-offset-reset: earliest
management:
endpoint:
shutdown:
enabled: true
info:
kafka:
- bootstrap-server: ${simple.consumer.bootstrap-servers}
- client-id: ${simple.consumer.client-id}
- group-id: ${simple.consumer.group-id}
+ bootstrap-server: ${spring.kafka.bootstrap-servers}
+ client-id: ${spring.kafka.client-id}
+ group-id: ${spring.kafka.consumer.group-id}
topic: ${simple.consumer.topic}
- auto-offset-reset: ${simple.consumer.auto-offset-reset}
+ auto-offset-reset: ${spring.kafka.consumer.auto-offset-reset}
+spring:
+ kafka:
+ bootstrap-servers: :9092
+ client-id: DEV
+ consumer:
+ group-id: my-group
+ auto-offset-reset: earliest
+ auto-commit-interval: 5s
+ key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+ value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+ properties:
+ partition.assignment.strategy: org.apache.kafka.clients.consumer.StickyAssignor
+ metadata.max.age.ms: 1000
logging:
level:
root: INFO
de.juplo: DEBUG
+ org.springframework.kafka: INFO
server:
port: 8881