MINOR: improve flaky Streams system test

Handle TimeoutException in Producer callback and retry sending input data Author: Matthias J. Sax <[email protected]> Reviewers: Damian Guy <[email protected]> Closes apache#4244 from mjsax/improve-flaky-system-test
liangjiezhu · Nov 22, 2017 · 80038e6 · 80038e6
1 parent 225b0b9
commit 80038e6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java b/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java
@@ -139,6 +139,7 @@ public static Map<String, Set<Integer>> generate(String kafka, final int numKeys
         // 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);