top10: 1.4.0 - Refined output JSON -- MOVE
[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / top10 / Top10StreamProcessorTopologyTest.java
index cca9a3a..a8fc859 100644 (file)
@@ -111,7 +111,7 @@ public class Top10StreamProcessorTopologyTest
     jsonSerializer.configure(
         Map.of(
             JsonSerializer.TYPE_MAPPINGS,
-            "word:" + TestWord.class.getName() + "," +
+            "key:" + TestWord.class.getName() + "," +
             "counter:" + TestCounter.class.getName()),
         isKey);
     return jsonSerializer;