X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Ftop10%2FTestOutputWord.java;h=132f6ba214256547554f5540e9e3bea45da690f1;hb=123d1d3df7e3665dbe511a2e7d7398e0aa235a63;hp=cfc2caef40aec8bf13a4b09a9bb70944a3c89fbb;hpb=f9156ed2e1f43b64d39cc39a13d12ca8c0d24219;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;
 }