X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryStreamProcessor.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryStreamProcessor.java;h=ff7c1501c0a7cae4e2373d729bf240f18677ff47;hb=57f47fca712981116b726e437f589ac727c5d0a7;hp=c4ae4ae0a0ecdd3cee579096b16b4006060968c3;hpb=dcb383aef4f4f454e3a1aed9cf1f2a599c7b1bb9;p=demos%2Fkafka%2Fwordcount

diff --git a/src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java b/src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java
index c4ae4ae..ff7c150 100644
--- a/src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java
+++ b/src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java
@@ -88,7 +88,7 @@ public class QueryStreamProcessor
 		return topology;
 	}
 
-	ReadOnlyKeyValueStore<String, String> getStore()
+	ReadOnlyKeyValueStore<String, UserRanking> getStore()
 	{
 		return streams.store(storeParameters);
 	}