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

   1 consumer:
   2   topic: test
   3 management:
   4   endpoint:
   5     shutdown:
   6       enabled: true
   7   endpoints:
   8     web:
   9       exposure:
  10         include: "*"
  11   info:
  12     env:
  13       enabled: true
  14     java:
  15       enabled: true
  16 info:
  17   kafka:
  18     bootstrap-server: ${spring.kafka.consumer.bootstrap-servers}
  19     client-id: ${spring.kafka.consumer.client-id}
  20     group-id: ${spring.kafka.consumer.group-id}
  21     topic: ${consumer.topic}
  22     auto-offset-reset: ${spring.kafka.consumer.auto-offset-reset}
  23 spring:
  24   kafka:
  25     consumer:
  26       bootstrap-servers: :9092
  27       client-id: DEV
  28       auto-offset-reset: earliest
  29       group-id: my-group
  30       value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
  31       properties:
  32         spring.json.type.mapping: "message:de.juplo.kafka.ClientMessage"
  33         spring.json.trusted.packages: "de.juplo.kafka"
  34 logging:
  35   level:
  36     root: INFO
  37     de.juplo: DEBUG
  38 server:
  39   port: 8881