producer:
- bootstrap-server: :9092
- client-id: peter
+ client-id: DEV
topic: test
- acks: 1
- throttle-ms: 1000
management:
+ endpoint:
+ shutdown:
+ enabled: true
endpoints:
web:
exposure:
include: "*"
+ info:
+ env:
+ enabled: true
+ java:
+ enabled: true
+info:
+ kafka:
+ bootstrap-servers: ${spring.kafka.bootstrap-servers}
+ client-id: ${producer.client-id}
+ topic: ${spring.kafka.template.default-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
+ producer:
+ acks: -1
+ batch-size: 16384
+ compression-type: gzip
+ key-serializer: org.apache.kafka.common.serialization.StringSerializer
+ value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
+ properties:
+ linger.ms: 0
+ delivery.timeout.ms: 20000 # 20 Sekunden
+ request.timeout.ms: 10000 # 10 Sekunden
+ spring.json.type.mapping: >
+ message:de.juplo.kafka.ClientMessage,
+ foo:de.juplo.kafka.FooMessage,
+ greeting:de.juplo.kafka.Greeting
+ template:
+ default-topic: test
logging:
level:
root: INFO
de.juplo: DEBUG
+server:
+ port: 8880