X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryApplicationConfiguration.java;h=0f9cad1ef6327feab9e84e889b7aacaf372214ae;hb=d835b70fc4d49a50f42da9c21b3de1dbcd18cbaf;hp=440d5c4649b0fdb328a7c51e2df8ea8c6e461cf5;hpb=b52ff02b6952dfc708c7c7d94205b5b24afd68f9;p=demos%2Fkafka%2Fwordcount

diff --git a/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java b/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java
index 440d5c4..0f9cad1 100644
--- a/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java
@@ -89,7 +89,7 @@ public class QueryApplicationConfiguration
 		props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, JsonSerde.class.getName());
 		props.put(
 				JsonDeserializer.TYPE_MAPPINGS,
-				"user:" + Key.class.getName() + "," +
+				"stats:" + Key.class.getName() + "," +
 				"ranking:" + Ranking.class.getName() + "," +
 				"userranking:" + UserRanking.class.getName());