X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fresources%2Fapplication.properties;h=94e749262e2fb5f9e2c63f7f0fe650ce7d22da4d;hb=9c9ffbe3316ed295533c576e823794aa6de99665;hp=0d2624f4710f0d6b6a3d84727cae7048662fedf4;hpb=0e63376a3cfc8ecabdc4699e9307f6a51415cb09;p=demos%2Fkafka%2Fwordcount diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 0d2624f..94e7492 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -1,3 +1,10 @@ server.port=8086 management.endpoints.web.exposure.include=* logging.level.de.juplo.kafka.wordcount.splitter=DEBUG +spring.kafka.consumer.auto-offset-reset. earliest +spring.kafka.consumer.group-id=splitter +spring.kafka.bootstrap-servers=localhost:9092 +spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer +spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer +spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer +spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer