counter: 1.2.15 - Refined `TestData` (explicit key in input-data)

[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / counter / CounterApplicationIT.java

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 (file)
--- 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))