X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Ftop10%2FCounter.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Ftop10%2FCounter.java;h=c16b70b0fd3d0cdcd0aed251c3a3753b933bfb10;hb=87f82fe35276666d298bc5100f0810b6aa6ce2d4;hp=0000000000000000000000000000000000000000;hpb=e606cd45ad11978fc2b810c3ddf35d7bd2349220;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/top10/Counter.java b/src/test/java/de/juplo/kafka/wordcount/top10/Counter.java
new file mode 100644
index 0000000..c16b70b
--- /dev/null
+++ b/src/test/java/de/juplo/kafka/wordcount/top10/Counter.java
@@ -0,0 +1,14 @@
+package de.juplo.kafka.wordcount.top10;
+
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.*;
+
+
+@Value(staticConstructor = "of")
+public class Counter
+{
+  String user;
+  String word;
+  long counter;
+}