[pulsar] branch master updated: Fix warn log on the producer side when duplicate message is dropped (#8729)

[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 bad2e3f  Fix warn log on the producer side when duplicate message is dropped (#8729)
bad2e3f is described below

commit bad2e3f13f84f095eee9b00bd1a049f228e22cef
Author: Masahiro Sakamoto <ma...@yahoo-corp.jp>
AuthorDate: Sat Nov 28 01:34:23 2020 +0900

    Fix warn log on the producer side when duplicate message is dropped (#8729)
---
 .../src/main/java/org/apache/pulsar/client/impl/ClientCnx.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
index 44a93b4..8a008e8 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
@@ -367,8 +367,8 @@ public class ClientCnx extends PulsarHandler {
         }
 
         if (ledgerId == -1 && entryId == -1) {
-            log.warn("[{}] Message has been dropped for non-persistent topic producer-id {}-{}", ctx.channel(),
-                    producerId, sequenceId);
+            log.warn("{} Message with sequence-id {} published by producer {} has been dropped", ctx.channel(),
+                    sequenceId, producerId);
         }
 
         if (log.isDebugEnabled()) {