[pulsar] branch master updated: Debug log: include ledgerId for dispatched message (#3465)

[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 93e9720  Debug log: include ledgerId for dispatched message (#3465)
93e9720 is described below

commit 93e9720c7001133eac1eaf84b7cd6c8f170b9e06
Author: Rajan Dhabalia <rd...@apache.org>
AuthorDate: Sun Feb 3 13:31:31 2019 -0800

    Debug log: include ledgerId for dispatched message (#3465)
---
 .../src/main/java/org/apache/pulsar/broker/service/Consumer.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
index ad2ee7b..e8d6057 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
@@ -256,8 +256,8 @@ public class Consumer {
                 }
 
                 if (log.isDebugEnabled()) {
-                    log.debug("[{}-{}] Sending message to consumerId {}, entry id {}", topicName, subscription,
-                            consumerId, pos.getEntryId());
+                    log.debug("[{}-{}] Sending message to consumerId {}, msg id {}-{}", topicName, subscription,
+                            consumerId, pos.getLedgerId(), pos.getEntryId());
                 }
 
                 // We only want to pass the "real" promise on the last entry written