X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fresources%2Fapplication.yml;h=d524e5f876ea271c5348198eb73d144196fe5ac8;hb=a5657bf81a9b613689dc40ef59449045e91908c6;hp=ae7aae8a4ece4d01ae931c2b55d268fc8bd17686;hpb=255052b2411353652f5ec879c2f6ce7fe6c54969;p=demos%2Fkafka%2Ftraining diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index ae7aae8..d524e5f 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -16,10 +16,10 @@ management: enabled: true info: kafka: - bootstrap-server: ${spring.kafka.consumer.bootstrap-servers} - client-id: ${spring.kafka.consumer.client-id} + bootstrap-server: ${spring.kafka.bootstrap-servers} + client-id: ${spring.kafka.client-id} group-id: ${spring.kafka.consumer.group-id} - topic: ${consumer.topic} + topic: ${simple.consumer.topic} auto-offset-reset: ${spring.kafka.consumer.auto-offset-reset} spring: kafka: @@ -30,7 +30,7 @@ spring: auto-offset-reset: earliest auto-commit-interval: 5s key-deserializer: org.apache.kafka.common.serialization.StringDeserializer - value-deserializer: org.springframework.kafka.support.serializer.StringDeserializer + value-deserializer: org.apache.kafka.common.serialization.StringDeserializer properties: partition.assignment.strategy: org.apache.kafka.clients.consumer.StickyAssignor metadata.max.age.ms: 1000