Repository: kafka Updated Branches: refs/heads/trunk 225b0b9c7 -> 80038e6d2
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 #4244 from mjsax/improve-flaky-system-test Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/80038e6d Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/80038e6d Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/80038e6d Branch: refs/heads/trunk Commit: 80038e6d205a037ee969f1c5839ec03925cd8ba4 Parents: 225b0b9 Author: Matthias J. Sax <[email protected]> Authored: Wed Nov 22 10:53:32 2017 +0000 Committer: Damian Guy <[email protected]> Committed: Wed Nov 22 10:53:32 2017 +0000 ---------------------------------------------------------------------- .../test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/80038e6d/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java ---------------------------------------------------------------------- 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 index 9f8bcc3..a5aef2a 100644 --- 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 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);
