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=696e08862abd823f6508cd1e0e18d4227b8a15c4;hb=0d1ed8c65f422e5c0cd291c35dba67b1f2205997;hp=f7dc75032da58301ebb675c7891c93cf37dbaf46;hpb=101100b6dba432bb61952a1ddb2dac46d04f0750;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 f7dc750..696e088 100644
--- a/src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java
+++ b/src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java
@@ -99,7 +99,7 @@ public class QueryStreamProcessor
 		HostInfo activeHost = metadata.activeHost();
 		log.debug("Local store for {}: {}, {}:{}", username, metadata.partition(), activeHost.host(), activeHost.port());
 
-		if (activeHost.equals(this.hostInfo))
+		if (activeHost.equals(this.hostInfo) || activeHost.equals(HostInfo.unavailable()))
 		{
 			return Optional.empty();
 		}