add log

Technoboy- · Aug 18, 2023 · b64ee22 · b64ee22
1 parent 33681e6
commit b64ee22
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java
@@ -158,6 +158,7 @@ void tryCompletePending() {
                 MessageIdData messageId = messageAndCnx.msg.getMessageIdData();
                 lastDequeuedMessageId = new BatchMessageIdImpl(messageId.getLedgerId(), messageId.getEntryId(),
                     messageId.getPartition(), numMsg - 1);
+                log.info("update lastDequeuedMessageId: {}, lastDequeuedMessageId");
 
                 ClientCnx currentCnx = cnx();
                 if (currentCnx == messageAndCnx.cnx) {