From ddd27dcaa846578c4ad4cb68a9516e47f8bcfdb5 Mon Sep 17 00:00:00 2001 From: Tim Brooks Date: Fri, 3 Apr 2015 12:29:48 -0500 Subject: [PATCH] Remove a duplicate check to metadataFetchInProgress --- clients/src/main/java/org/apache/kafka/clients/NetworkClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java index f429502..b7ae595 100644 --- a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java +++ b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java @@ -214,7 +214,7 @@ public class NetworkClient implements KafkaClient { // if there is no node available to connect, back off refreshing metadata long metadataTimeout = Math.max(Math.max(timeToNextMetadataUpdate, timeToNextReconnectAttempt), waitForMetadataFetch); - if (!this.metadataFetchInProgress && metadataTimeout == 0) + if (metadataTimeout == 0) maybeUpdateMetadata(now); // do the I/O try { -- 2.3.5