X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FMessage.java;h=eb64e6d47a7a6dc62f793687dc71dff052794f78;hb=ff29d17cc2b1fa9b465c1874e387c23b7d7adc4e;hp=8ed7cc5d8e8f905b4d674747f96d6304fe936aab;hpb=0a7e20af38fe1502c7c4328b2b6024cfe9e7b019;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;
 }