Browse Source

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.thereska@gmail.com>

Reviewers: Damian Guy, Guozhang Wang

Closes #1899 from enothereska/hotfix-smoke-test-commit-interval
pull/1866/merge
Eno Thereska 8 years ago committed by Guozhang Wang
parent
commit
4112bc3af7
  1. 1
      streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java

1
streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java

@ -89,6 +89,7 @@ public class SmokeTestClient extends SmokeTestUtil { @@ -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();

Loading…
Cancel
Save