kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: KAFKA-5464; StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG
Date Thu, 06 Jul 2017 08:46:33 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.11.0 c50bee94a -> 784be9bd1


KAFKA-5464; StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG

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

Reviewers: Eno Thereska <eno.thereska@gmail.com>, Damian Guy <damian.guy@gmail.com>

Closes #3439 from mjsax/kafka-5464-streamskafkaclient-poll

(cherry picked from commit f53f5eaa1bce0129bac7b8ffac3a8da11d2ee574)
Signed-off-by: Damian Guy <damian.guy@gmail.com>


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

Branch: refs/heads/0.11.0
Commit: 784be9bd1ba279641f99411fab566ca936d3a5ed
Parents: c50bee9
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Thu Jul 6 09:46:11 2017 +0100
Committer: Damian Guy <damian.guy@gmail.com>
Committed: Thu Jul 6 09:46:26 2017 +0100

----------------------------------------------------------------------
 .../kafka/streams/processor/internals/StreamsKafkaClient.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/784be9bd/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 ebb3344..ce593df 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(streamsConfig.getLong(StreamsConfig.POLL_MS_CONFIG), Time.SYSTEM.milliseconds());
+                kafkaClient.poll(0, Time.SYSTEM.milliseconds());
             } catch (final Exception e) {
                 throw new StreamsException("Could not poll.", e);
             }
@@ -266,7 +266,7 @@ public class StreamsKafkaClient {
         while (Time.SYSTEM.milliseconds() < responseTimeout) {
             final List<ClientResponse> responseList;
             try {
-                responseList = kafkaClient.poll(streamsConfig.getLong(StreamsConfig.POLL_MS_CONFIG),
Time.SYSTEM.milliseconds());
+                responseList = kafkaClient.poll(100, Time.SYSTEM.milliseconds());
             } catch (final IllegalStateException e) {
                 throw new StreamsException("Could not poll.", e);
             }


Mime
View raw message