Repository: kafka Updated Branches: refs/heads/trunk ad8e7cf5e -> 2244c68eb
MINOR: expose commit interval config for SimpleBenchmark Expose the streams commit interval config for different testing scenarios. Author: Bill Bejeck <b...@confluent.io> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #3244 from bbejeck/MINOR_add_commit_config_benchmark Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2244c68e Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/2244c68e Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/2244c68e Branch: refs/heads/trunk Commit: 2244c68ebc4b016e1a037026f625a2ecceb852a3 Parents: ad8e7cf Author: Bill Bejeck <b...@confluent.io> Authored: Tue Jun 6 10:57:47 2017 -0700 Committer: Guozhang Wang <wangg...@gmail.com> Committed: Tue Jun 6 10:57:47 2017 -0700 ---------------------------------------------------------------------- .../test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/2244c68e/streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java ---------------------------------------------------------------------- diff --git a/streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java b/streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java index 6d6ec1d..2983df5 100644 --- a/streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java +++ b/streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java @@ -106,6 +106,7 @@ public class SimpleBenchmark { private static long processedBytes = 0; private static final int VALUE_SIZE = 100; private static final long POLL_MS = 500L; + private static final long COMMIT_INTERVAL_MS = 30000L; private static final int MAX_POLL_RECORDS = 1000; private static final int SOCKET_SIZE_BYTES = 1 * 1024 * 1024; @@ -218,6 +219,7 @@ public class SimpleBenchmark { props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.ByteArray().getClass()); props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, MAX_POLL_RECORDS); props.put(StreamsConfig.POLL_MS_CONFIG, POLL_MS); + props.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, COMMIT_INTERVAL_MS); return props; }