This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push: new caecc16 MINOR: ConsumerNetworkClient does not need to send the remaining requests when the node is not ready (#6264) caecc16 is described below commit caecc16b5cc9c85acda50d68384a1ff9ebf930c9 Author: lambdaliu <lambda.tenc...@gmail.com> AuthorDate: Sat Mar 2 00:54:57 2019 +0800 MINOR: ConsumerNetworkClient does not need to send the remaining requests when the node is not ready (#6264) Reviewers: Guozhang Wang <wangg...@gmail.com> --- .../apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java | 3 +++ 1 file changed, 3 insertions(+) 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 924b3ef..9aa8eaa 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 @@ -474,6 +474,9 @@ public class ConsumerNetworkClient implements Closeable { if (client.ready(node, now)) { client.send(request, now); iterator.remove(); + } else { + // try next node when current node is not ready + break; } } }