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