--- /dev/null
+package de.juplo.kafka.wordcount.counter;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor(staticName = "of")
+public class TestCounter
+{
+ String user;
+ String word;
+ long counter;
+
+ public static TestCounter of(TestWord word, long counter)
+ {
+ return new TestCounter(word.getUser(), word.getWord(), counter);
+ }
+}