kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: increase request timeout for streams bounce test
Date Mon, 04 Dec 2017 17:56:38 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 9204197ab -> 39c438ec1


MINOR: increase request timeout for streams bounce test

Increase `REQUEST_TIMOUT_MS` to improve a flaky system test until KIP-91 merged

Author: Bill Bejeck <bill@confluent.io>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #4291 from bbejeck/MINOR_increase_request_timeout_for_streams_bounce_test


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

Branch: refs/heads/trunk
Commit: 39c438ec1f0830e8a651315cb24059ae290645ea
Parents: 9204197
Author: Bill Bejeck <bill@confluent.io>
Authored: Mon Dec 4 09:56:34 2017 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Mon Dec 4 09:56:34 2017 -0800

----------------------------------------------------------------------
 .../test/java/org/apache/kafka/streams/tests/SmokeTestClient.java  | 2 +-
 .../test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/39c438ec/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java b/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java
index 887f763..727c421 100644
--- a/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java
+++ b/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java
@@ -108,7 +108,7 @@ public class SmokeTestClient extends SmokeTestUtil {
         props.put(ProducerConfig.RETRIES_CONFIG, Integer.MAX_VALUE);
         props.put(ProducerConfig.ACKS_CONFIG, "all");
         //TODO remove this config or set to smaller value when KIP-91 is merged
-        props.put(StreamsConfig.producerPrefix(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG),
60000);
+        props.put(StreamsConfig.producerPrefix(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG),
80000);
 
         StreamsBuilder builder = new StreamsBuilder();
         Consumed<String, Integer> stringIntConsumed = Consumed.with(stringSerde, intSerde);

http://git-wip-us.apache.org/repos/asf/kafka/blob/39c438ec/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 a5aef2a..81dd66b 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,7 +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);
+        producerProps.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG, 80000);
 
         KafkaProducer<byte[], byte[]> producer = new KafkaProducer<>(producerProps);
 


Mime
View raw message