root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR - Increase the number of Trogdor Histogram buckets to 10000 (#8627) 

Reviewers: Colin P. McCabe <cmccabe@apache.org>
This commit is contained in:
Scott Hendricks 2020-05-07 00:10:19 -04:00 committed by GitHub
parent 29dd1148c8
commit 5203ab0c5d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java
View File

@ -200,7 +200,7 @@ public class ConsumeBenchWorker implements TaskWorker {
private final ThreadSafeConsumer consumer; private final ThreadSafeConsumer consumer;
private ConsumeMessages(ThreadSafeConsumer consumer) { private ConsumeMessages(ThreadSafeConsumer consumer) {
this.latencyHistogram = new Histogram(5000); this.latencyHistogram = new Histogram(10000);
this.messageSizeHistogram = new Histogram(2 * 1024 * 1024); this.messageSizeHistogram = new Histogram(2 * 1024 * 1024);
this.clientId = consumer.clientId(); this.clientId = consumer.clientId();
this.statusUpdaterFuture = executor.scheduleAtFixedRate( this.statusUpdaterFuture = executor.scheduleAtFixedRate(

2
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java
View File

@ -195,7 +195,7 @@ public class ProduceBenchWorker implements TaskWorker {
SendRecords(HashSet<TopicPartition> activePartitions) { SendRecords(HashSet<TopicPartition> activePartitions) {
this.activePartitions = activePartitions; this.activePartitions = activePartitions;
this.partitionsIterator = activePartitions.iterator(); this.partitionsIterator = activePartitions.iterator();
this.histogram = new Histogram(5000); this.histogram = new Histogram(10000);
this.transactionGenerator = spec.transactionGenerator(); this.transactionGenerator = spec.transactionGenerator();
this.enableTransactions = this.transactionGenerator.isPresent(); this.enableTransactions = this.transactionGenerator.isPresent();