MINOR: improve flaky Streams system test
Handle TimeoutException in Producer callback and retry sending input data
Author: Matthias J. Sax
Reviewers: Damian Guy
Closes from mjsax/improve-flaky-system-test
@@ -139,6 +139,7 @@ public class SmokeTestDriver extends SmokeTestUtil {
// no duplicates
producerProps.put(ProducerConfig.RETRIES_CONFIG, Integer.MAX_VALUE);
producerProps.put(ProducerConfig.ACKS_CONFIG, "all");
+ producerProps.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG, 45000);
KafkaProducer<byte[], byte[]> producer = new KafkaProducer<>(producerProps);
