From 4112bc3af7bec63ae1248c1b9db745ba8ac4c63c Mon Sep 17 00:00:00 2001 From: Eno Thereska Date: Thu, 22 Sep 2016 12:45:43 -0700 Subject: [PATCH] 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 Reviewers: Damian Guy, Guozhang Wang Closes #1899 from enothereska/hotfix-smoke-test-commit-interval --- .../java/org/apache/kafka/streams/smoketest/SmokeTestClient.java | 1 + 1 file changed, 1 insertion(+) 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 ba71e055550..f920c515c0e 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();