X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fresources%2Fapplication.yml;fp=src%2Fmain%2Fresources%2Fapplication.yml;h=fe43d9ad93dc3fdb31fa290281f72f631d800fd9;hb=5e39ed9165faec9664b5fe2415a65a3f0c756477;hp=ae7aae8a4ece4d01ae931c2b55d268fc8bd17686;hpb=b1b6f4890362d5e36f9e5478b69207415ad4b18c;p=demos%2Fkafka%2Ftraining diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index ae7aae8..fe43d9a 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -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