X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterApplicationProperties.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterApplicationProperties.java;h=351ea18ea0ebfdbc9b08996b2211104bd9f8a75e;hb=fe049944648d9675ffe66b586b6bf860fbac696f;hp=d670ba23b7e2700d05e3587c9b1071c507b767dc;hpb=b1623c2b645c614424ceec3bc71008c900d82115;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..351ea18 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,6 @@ public class CounterApplicationProperties { private String bootstrapServer = "localhost:9092"; private String applicationId = "counter"; - private String inputTopic = "recordings"; + private String inputTopic = "words"; private String outputTopic = "countings"; }