You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2017/11/22 10:53:45 UTC
kafka git commit: MINOR: improve flaky Streams system test
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 <ma...@confluent.io>
Reviewers: Damian Guy <da...@gmail.com>
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 <ma...@confluent.io>
Authored: Wed Nov 22 10:53:32 2017 +0000
Committer: Damian Guy <da...@gmail.com>
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);