query:1.0.2 - Fixed responses for availability edge-cases

[demos/kafka/wordcount] / src / main / java / de / juplo / kafka / wordcount / query / QueryStreamProcessor.java

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 (file)
--- 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();
                }