query: 2.0.0 - (RED) Corrected expectations for the ``users``-input-topic

[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / query / QueryStreamProcessorTopologyTest.java

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 1a857b7..fda7408 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/query/QueryStreamProcessorTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/query/QueryStreamProcessorTopologyTest.java
@@ -52,7 +52,7 @@ public class QueryStreamProcessorTopologyTest
     userIn = testDriver.createInputTopic(
         USERS_IN,
         new StringSerializer(),
-        jsonSerializer(TestUserData.class));
+        jsonSerializer(TestUserData.class).noTypeInfo());
   }
 
 
@@ -82,7 +82,6 @@ public class QueryStreamProcessorTopologyTest
     jsonSerializer.configure(
         Map.of(
             JsonSerializer.TYPE_MAPPINGS,
-            "userdata:" + TestUserData.class.getName() + "," +
             "ranking:" + TestRanking.class.getName()),
         false);
     return jsonSerializer;