X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FTestCounter.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FTestCounter.java;h=b78c4294f853d50e279f1b1fbeb19ebcdac79464;hb=5030aed19804a0c48f1968208e176657bdd147de;hp=d98ae649ba6beb34321a70dcc344f499f1959afd;hpb=066ac7e345947764b28084b9961b1633264d63d0;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/TestCounter.java b/src/test/java/de/juplo/kafka/wordcount/counter/TestCounter.java
index d98ae64..b78c429 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/TestCounter.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/TestCounter.java
@@ -10,12 +10,6 @@ import lombok.NoArgsConstructor;
 @AllArgsConstructor(staticName = "of")
 public class TestCounter
 {
-  String user;
-  String word;
+  String key;
   long counter;
-
-  public static TestCounter of(TestWord word, long counter)
-  {
-    return new TestCounter(word.getUser(), word.getWord(), counter);
-  }
 }