You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2018/12/12 16:29:20 UTC
[kafka] branch trunk updated: MINOR: Add unit for max latency in
ProducerPerformance output (#6014)
This is an automated email from the ASF dual-hosted git repository.
jgus 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 3ef6b0f MINOR: Add unit for max latency in ProducerPerformance output (#6014)
3ef6b0f is described below
commit 3ef6b0fce05a6ecdf7a703ff48680b16594b7bc4
Author: Arjun Satish <wi...@users.noreply.github.com>
AuthorDate: Wed Dec 12 08:28:58 2018 -0800
MINOR: Add unit for max latency in ProducerPerformance output (#6014)
Reviewers: Jason Gustafson <ja...@confluent.io>
---
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java b/tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java
index 6dba510..dbb95bf 100644
--- a/tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java
+++ b/tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java
@@ -359,7 +359,7 @@ public class ProducerPerformance {
long ellapsed = System.currentTimeMillis() - windowStart;
double recsPerSec = 1000.0 * windowCount / (double) ellapsed;
double mbPerSec = 1000.0 * this.windowBytes / (double) ellapsed / (1024.0 * 1024.0);
- System.out.printf("%d records sent, %.1f records/sec (%.2f MB/sec), %.1f ms avg latency, %.1f max latency.%n",
+ System.out.printf("%d records sent, %.1f records/sec (%.2f MB/sec), %.1f ms avg latency, %.1f ms max latency.%n",
windowCount,
recsPerSec,
mbPerSec,