Repository: kafka
Updated Branches:
  refs/heads/trunk 27e3edc79 -> 4112bc3af


HOTFIX: Decrease commit interval

The original commit interval of 30 seconds might be too large in some cases, 
e.g., when the verifier finishes before those 30 seconds have elapsed.

Author: Eno Thereska <eno.there...@gmail.com>

Reviewers: Damian Guy, Guozhang Wang

Closes #1899 from enothereska/hotfix-smoke-test-commit-interval


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

Branch: refs/heads/trunk
Commit: 4112bc3af7bec63ae1248c1b9db745ba8ac4c63c
Parents: 27e3edc
Author: Eno Thereska <eno.there...@gmail.com>
Authored: Thu Sep 22 12:45:43 2016 -0700
Committer: Guozhang Wang <wangg...@gmail.com>
Committed: Thu Sep 22 12:45:43 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/streams/smoketest/SmokeTestClient.java    | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/4112bc3a/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java
----------------------------------------------------------------------
diff --git 
a/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java 
b/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java
index ba71e05..f920c51 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java
@@ -89,6 +89,7 @@ public class SmokeTestClient extends SmokeTestUtil {
         props.put(StreamsConfig.NUM_STANDBY_REPLICAS_CONFIG, 2);
         props.put(StreamsConfig.BUFFERED_RECORDS_PER_PARTITION_CONFIG, 100);
         props.put(StreamsConfig.REPLICATION_FACTOR_CONFIG, 2);
+        props.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 1000);
         props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
 
         KStreamBuilder builder = new KStreamBuilder();

Reply via email to