Fix consumer stats log error. (apache#3327)

drianpauL · Jan 8, 2019 · ad72b7e · ad72b7e
1 parent ccfa389
commit ad72b7e
Showing 1 changed file with 2 additions and 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
@@ -131,8 +131,8 @@ private void init(ConsumerConfigurationData<?> conf) {
                 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),