Fix warn log on the producer side when duplicate message is dropped
@@ -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()) {
