X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterApplicationProperties.java;h=c3ada172e05cdf2d1cc800b63aedbd53f67ba4bb;hb=db4b181f863add3e78c01d110c1b4feabd8ecb89;hp=d670ba23b7e2700d05e3587c9b1071c507b767dc;hpb=02ab54c6b3c099f5b0bd420fc0a37034badf1c71;p=demos%2Fkafka%2Fwordcount diff --git a/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationProperties.java b/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationProperties.java index d670ba2..c3ada17 100644 --- a/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationProperties.java +++ b/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationProperties.java @@ -15,6 +15,8 @@ public class CounterApplicationProperties { private String bootstrapServer = "localhost:9092"; private String applicationId = "counter"; - private String inputTopic = "recordings"; + private String inputTopic = "words"; private String outputTopic = "countings"; + private Integer commitInterval; + private Integer cacheMaxBytes; }