You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/06/06 17:57:52 UTC
kafka git commit: MINOR: expose commit interval config for
SimpleBenchmark
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 <bi...@confluent.io>
Reviewers: Guozhang Wang <wa...@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 <bi...@confluent.io>
Authored: Tue Jun 6 10:57:47 2017 -0700
Committer: Guozhang Wang <wa...@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;
}