StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG
Author: Matthias J. Sax
Reviewers: Eno Thereska Damian Guy
Closes from mjsax/kafka-5464-streamskafkaclient-poll
@@ -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);
}
