X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryApplicationConfiguration.java;h=440d5c4649b0fdb328a7c51e2df8ea8c6e461cf5;hb=700f80444d14b201f7b696fb5b7bcab0d767f007;hp=2ece744facc6e7ee3c8db840d213488e22f6bc78;hpb=f18423d411650c6f08c9b698b92c33c42bdd670f;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 2ece744..440d5c4 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,13 +85,12 @@ 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() + "," +
 				"ranking:" + Ranking.class.getName() + "," +
-				"userdata:" + User.class.getName() + "," +
 				"userranking:" + UserRanking.class.getName());
 
 		return props;