[pulsar] branch master updated: Fix consumer stats log error. (#3327)

[mm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new ad72b7e  Fix consumer stats log error. (#3327)
ad72b7e is described below

commit ad72b7e40d48a68700ff01b268eb791b0c50950d
Author: penghui <co...@gmail.com>
AuthorDate: Wed Jan 9 02:27:54 2019 +0800

    Fix consumer stats log error. (#3327)
---
 .../java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java
index 01c51cc..e330b57 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java
@@ -131,8 +131,8 @@ public class ConsumerStatsRecorderImpl implements ConsumerStatsRecorder {
                 if ((currentNumMsgsReceived | currentNumBytesReceived | currentNumReceiveFailed | currentNumAcksSent
                         | currentNumAcksFailed) != 0) {
                     log.info(
-                            "[{}] [{}] [{}] Prefetched messages: {} --- Consume throughput: {} msgs/s --- "
-                                    + "Throughput received: {} msg/s --- {} Mbit/s --- "
+                            "[{}] [{}] [{}] Prefetched messages: {} --- "
+                                    + "Consume throughput received: {} msgs/s --- {} Mbit/s --- "
                                     + "Ack sent rate: {} ack/s --- " + "Failed messages: {} --- " + "Failed acks: {}",
                             consumer.getTopic(), consumer.getSubscription(), consumer.consumerName,
                             consumer.incomingMessages.size(), THROUGHPUT_FORMAT.format(receivedMsgsRate),