X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FMessage.java;h=eb64e6d47a7a6dc62f793687dc71dff052794f78;hb=refs%2Ftags%2Fcounter-1.2.9;hp=8ed7cc5d8e8f905b4d674747f96d6304fe936aab;hpb=f9106e5166ce84caa2a910aa21fb41efaebcc73f;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/Message.java b/src/test/java/de/juplo/kafka/wordcount/counter/Message.java
index 8ed7cc5..eb64e6d 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/Message.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/Message.java
@@ -6,6 +6,6 @@ import lombok.Value;
 @Value(staticConstructor = "of")
 public class Message
 {
-  String key;
-  String value;
+  Word key;
+  WordCount value;
 }