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=6c7844d823c88b549079639ea0d34d81d20fa703;hpb=913c2c4ec0a3584f6be27c8341898d17c4260501;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 6c7844d..0f9cad1 100644
--- a/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java
@@ -2,7 +2,6 @@ package de.juplo.kafka.wordcount.query;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
-import org.apache.kafka.common.serialization.Serdes;
 import org.apache.kafka.streams.StreamsConfig;
 import org.apache.kafka.streams.state.HostInfo;
 import org.apache.kafka.streams.state.KeyValueBytesStoreSupplier;
@@ -86,11 +85,11 @@ public class QueryApplicationConfiguration
 	{
 		Properties props = new Properties();
 
-		props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
+		props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, JsonSerde.class.getName());
 		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());