kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-5464: Follow up. Increase poll timeout
Date Fri, 07 Jul 2017 18:39:10 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 5015c4cb0 -> fab75162e


KAFKA-5464: Follow up. Increase poll timeout

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Ismael Juma <ismael@juma.me.uk>, Damian Guy <damian.guy@gmail.com>,
Guozhang Wang <wangguoz@gmail.com>

Closes #3496 from mjsax/KAFKA-5464-follow-up

(cherry picked from commit 35f9fa804b0391492d7914f60e9b1ae94c223ad9)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fab75162
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/fab75162
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/fab75162

Branch: refs/heads/0.10.2
Commit: fab75162e53928d428d7280edf2eefa6e62e796a
Parents: 5015c4c
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Fri Jul 7 11:38:35 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri Jul 7 11:39:03 2017 -0700

----------------------------------------------------------------------
 .../kafka/streams/processor/internals/StreamsKafkaClient.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/fab75162/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsKafkaClient.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsKafkaClient.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsKafkaClient.java
index 48b6916..8c0c29c 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsKafkaClient.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsKafkaClient.java
@@ -203,7 +203,7 @@ public class StreamsKafkaClient {
                 }
             }
             try {
-                kafkaClient.poll(0, Time.SYSTEM.milliseconds());
+                kafkaClient.poll(50, Time.SYSTEM.milliseconds());
             } catch (final Exception e) {
                 throw new StreamsException("Could not poll.", e);
             }


Mime
View raw message