X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryStreamProcessorTopologyTest.java;h=fda74087e2b6927e0a479a0a2837dd6dbb4f8fba;hb=a07e20011b1a22d120920e84c36683a9d42c3ac5;hp=1a857b7ae1fbcaa222561e65704548c162183017;hpb=cc8f4fcf721bcdd4129fa1c3dde6c168d90ac183;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 1a857b7..fda7408 100644
--- 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;