Follow up. Increase poll timeout
Author: Matthias J. Sax
Reviewers: Ismael Juma Damian Guy Guozhang Wang
Closes from mjsax/KAFKA-5464-follow-up
@@ -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);
}
