You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2020/05/07 04:10:58 UTC
[kafka] branch trunk updated: MINOR - Increase the number of
Trogdor Histogram buckets to 10000 (#8627)
This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 5203ab0 MINOR - Increase the number of Trogdor Histogram buckets to 10000 (#8627)
5203ab0 is described below
commit 5203ab0c5d71d7fad16a308c7b2706dc80b4255e
Author: Scott Hendricks <49...@users.noreply.github.com>
AuthorDate: Thu May 7 00:10:19 2020 -0400
MINOR - Increase the number of Trogdor Histogram buckets to 10000 (#8627)
Reviewers: Colin P. McCabe <cm...@apache.org>
---
.../main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java | 2 +-
.../main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java b/tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java
index a397f84..4e77dff 100644
--- a/tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java
+++ b/tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java
@@ -200,7 +200,7 @@ public class ConsumeBenchWorker implements TaskWorker {
private final ThreadSafeConsumer consumer;
private ConsumeMessages(ThreadSafeConsumer consumer) {
- this.latencyHistogram = new Histogram(5000);
+ this.latencyHistogram = new Histogram(10000);
this.messageSizeHistogram = new Histogram(2 * 1024 * 1024);
this.clientId = consumer.clientId();
this.statusUpdaterFuture = executor.scheduleAtFixedRate(
diff --git a/tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java b/tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java
index 770a174..4b262ef 100644
--- a/tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java
+++ b/tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java
@@ -195,7 +195,7 @@ public class ProduceBenchWorker implements TaskWorker {
SendRecords(HashSet<TopicPartition> activePartitions) {
this.activePartitions = activePartitions;
this.partitionsIterator = activePartitions.iterator();
- this.histogram = new Histogram(5000);
+ this.histogram = new Histogram(10000);
this.transactionGenerator = spec.transactionGenerator();
this.enableTransactions = this.transactionGenerator.isPresent();