X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryStreamProcessorTopologyTest.java;h=6bdd8fa402460759f0dc9e45061a26b7c7244f20;hb=cfd58858b9861e8d0e4c1d30896505a50f63255b;hp=8439be17ae94878505f9cae2f38d18a8cd299195;hpb=2b22a006cc57203406c8589687a6c729ebdbf40c;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/query/QueryStreamProcessorTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/query/QueryStreamProcessorTopologyTest.java
index 8439be1..6bdd8fa 100644
--- a/src/test/java/de/juplo/kafka/wordcount/query/QueryStreamProcessorTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/query/QueryStreamProcessorTopologyTest.java
@@ -65,7 +65,7 @@ public class QueryStreamProcessorTopologyTest
         .forEach(kv -> top10In.pipeInput(kv.key, kv.value));
 
     KeyValueStore<String, String> store = testDriver.getKeyValueStore(STORE_NAME);
-    TestData.assertExpectedState(store);
+    TestData.assertExpectedState(user -> store.get(user));
   }
 
   @AfterEach