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=351ea18ea0ebfdbc9b08996b2211104bd9f8a75e;hpb=8a56919f493faa0acc6eb939b9c78312a1418efa;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 351ea18..c3ada17 100644 --- a/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationProperties.java +++ b/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationProperties.java @@ -17,4 +17,6 @@ public class CounterApplicationProperties private String applicationId = "counter"; private String inputTopic = "words"; private String outputTopic = "countings"; + private Integer commitInterval; + private Integer cacheMaxBytes; }