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:56 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 026350c4e -> 5015c4cb0


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/5015c4cb
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5015c4cb
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5015c4cb

Branch: refs/heads/0.10.2
Commit: 5015c4cb07c19097ba13bc29210f9e16947ae7c3
Parents: 026350c
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:47 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/5015c4cb/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 d8058b8..48b6916 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(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);
             }
@@ -248,7 +248,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