X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterApplicationIT.java;h=2f1e0c3a2b2b9a02577264c7dc43c311e904dba4;hb=44f1ad5dcd50851ef5d93b1be759481d5a38f63a;hp=31bf6a6d6c1f898793e51f9481f4a07d295687aa;hpb=8dec693aef633b7b8097780f527039e697a1a9b9;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
index 31bf6a6..2f1e0c3 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
@@ -69,7 +69,7 @@ public class CounterApplicationIT
 	{
 		TestData
 				.getInputMessages()
-				.forEach(word -> kafkaTemplate.send(TOPIC_IN, word.getUser(), word));
+				.forEach(kv -> kafkaTemplate.send(TOPIC_IN, kv.key, kv.value));
 
 		await("Expected messages")
 				.atMost(Duration.ofSeconds(10))