Repository: kafka Updated Branches: refs/heads/trunk 194d1fc03 -> 2490b1c49
kafka-2090; Remove duplicate check to metadataFetchInProgress; patched by Tim Brook; reviewed by Ewen Cheslack-PostavaJun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2490b1c4 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/2490b1c4 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/2490b1c4 Branch: refs/heads/trunk Commit: 2490b1c4994295ba6c291b1109c5d67ebb4c244d Parents: 194d1fc Author: Tim Brooks <[email protected]> Authored: Wed Apr 8 19:06:05 2015 -0700 Committer: Jun Rao <[email protected]> Committed: Wed Apr 8 19:06:05 2015 -0700 ---------------------------------------------------------------------- clients/src/main/java/org/apache/kafka/clients/NetworkClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/2490b1c4/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java ---------------------------------------------------------------------- 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 {
