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:45 GMT
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 <matthias@confluent.io>

Reviewers: Damian Guy <damian.guy@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 <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: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);
 


Mime
View raw message