X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Ftop10%2FTestOutputWord.java;h=132f6ba214256547554f5540e9e3bea45da690f1;hb=refs%2Fheads%2Fcounter;hp=cfc2caef40aec8bf13a4b09a9bb70944a3c89fbb;hpb=3c23bfd42005211ac9812fba698ab74c8a6b7aa0;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/top10/TestOutputWord.java b/src/test/java/de/juplo/kafka/wordcount/top10/TestOutputWord.java
index cfc2cae..132f6ba 100644
--- a/src/test/java/de/juplo/kafka/wordcount/top10/TestOutputWord.java
+++ b/src/test/java/de/juplo/kafka/wordcount/top10/TestOutputWord.java
@@ -10,6 +10,7 @@ import lombok.NoArgsConstructor;
 @AllArgsConstructor(staticName = "of")
 public class TestOutputWord
 {
-  String user;
-  String word;
+  String type;
+  String channel;
+  String key;
 }