You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/07/07 18:38:40 UTC
kafka git commit: KAFKA-5464: Follow up. Increase poll timeout
Repository: kafka
Updated Branches:
refs/heads/trunk 75f1b757e -> 35f9fa804
KAFKA-5464: Follow up. Increase poll timeout
Author: Matthias J. Sax <ma...@confluent.io>
Reviewers: Ismael Juma <is...@juma.me.uk>, Damian Guy <da...@gmail.com>, Guozhang Wang <wa...@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 <ma...@confluent.io>
Authored: Fri Jul 7 11:38:35 2017 -0700
Committer: Guozhang Wang <wa...@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);
}