kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: MINOR: improve flaky Streams system test
Date Wed, 22 Nov 2017 10:53:55 GMT
Repository: kafka
Updated Branches:
  refs/heads/1.0 3139d2aba -> 8ff00faea


MINOR: improve flaky Streams system test

Handle TimeoutException in Producer callback and retry sending input data

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Damian Guy <damian.guy@gmail.com>

Closes #4244 from mjsax/improve-flaky-system-test

(cherry picked from commit 80038e6d205a037ee969f1c5839ec03925cd8ba4)
Signed-off-by: Damian Guy <damian.guy@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8ff00fae
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8ff00fae
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8ff00fae

Branch: refs/heads/1.0
Commit: 8ff00faea18a8bee54cdbb00b13ebd7baebca9cd
Parents: 3139d2a
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Wed Nov 22 10:53:32 2017 +0000
Committer: Damian Guy <damian.guy@gmail.com>
Committed: Wed Nov 22 10:53:45 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/8ff00fae/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);
 


Mime
View raw message