juplo.de Git - demos/kafka/training/blob - src/main/resources/application.yml

   1 producer:
   2   client-id: DEV
   3   topic: test
   4 management:
   5   endpoint:
   6     shutdown:
   7       enabled: true
   8   endpoints:
   9     web:
  10       exposure:
  11         include: "*"
  12   info:
  13     env:
  14       enabled: true
  15     java:
  16       enabled: true
  17 info:
  18   kafka:
  19     bootstrap-servers: ${spring.kafka.bootstrap-servers}
  20     client-id: ${producer.client-id}
  21     topic: ${spring.kafka.template.default-topic}
  22     acks: ${spring.kafka.producer.acks}
  23     batch-size: ${spring.kafka.producer.batch-size}
  24     linger-ms: ${spring.kafka.producer.properties.linger.ms}
  25     compression-type: ${spring.kafka.producer.compression-type}
  26 spring:
  27   kafka:
  28     bootstrap-servers: :9092
  29     producer:
  30       acks: -1
  31       batch-size: 16384
  32       compression-type: gzip
  33       key-serializer: org.apache.kafka.common.serialization.StringSerializer
  34       value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
  35       properties:
  36         linger.ms: 0
  37         delivery.timeout.ms: 20000 # 20 Sekunden
  38         request.timeout.ms: 10000 # 10 Sekunden
  39         spring.json.type.mapping: >
  40           message:de.juplo.kafka.ClientMessage,
  41           foo:de.juplo.kafka.FooMessage,
  42           greeting:de.juplo.kafka.Greeting
  43     template:
  44       default-topic: test
  45 logging:
  46   level:
  47     root: INFO
  48     de.juplo: DEBUG
  49 server:
  50   port: 8880