X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fpopular%2FWordCounter.java;h=bc4243efbd793fdf89837f297b293f93d2c955d8;hb=8af553a2b1cae0b7f5c9d9c63023b47af89bd5ab;hp=c94ec0e96e7889ff4d68f08e1bbf13d15372c98e;hpb=feb9d86212983d93d3546f5a4d9b15f14cd57314;p=demos%2Fkafka%2Fwordcount

diff --git a/src/main/java/de/juplo/kafka/wordcount/popular/WordCounter.java b/src/main/java/de/juplo/kafka/wordcount/popular/WordCounter.java
index c94ec0e..bc4243e 100644
--- a/src/main/java/de/juplo/kafka/wordcount/popular/WordCounter.java
+++ b/src/main/java/de/juplo/kafka/wordcount/popular/WordCounter.java
@@ -10,6 +10,6 @@ import lombok.NoArgsConstructor;
 @AllArgsConstructor(staticName = "of")
 public class WordCounter
 {
-  String word;
+  String key;
   long counter;
 }