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:38:40 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 75f1b757e -> 35f9fa804


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


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

Branch: refs/heads/trunk
Commit: 35f9fa804b0391492d7914f60e9b1ae94c223ad9
Parents: 75f1b75
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:38:35 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/35f9fa80/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 ce593df..148a51d 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
@@ -217,7 +217,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