diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java index c591074ba..9363b66b9 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java @@ -543,7 +543,7 @@ public class ConsumerNetworkClient implements Closeable { public boolean isUnavailable(Node node) { lock.lock(); try { - return client.connectionFailed(node) && client.connectionDelay(node, time.milliseconds()) > 0; + return client.connectionDelay(node, time.milliseconds()) > 0; } finally { lock.unlock(); }