[improve][client] Change the get lastMessageId to debug level
@@ -2375,7 +2375,9 @@ public class ConsumerImpl<T> extends ConsumerBase<T> implements ConnectionHandle
long requestId = client.newRequestId();
ByteBuf getLastIdCmd = Commands.newGetLastMessageId(consumerId, requestId);
- log.info("[{}][{}] Get topic last message Id", topic, subscription);
+ if (log.isDebugEnabled()) {
+ log.debug("[{}][{}] Get topic last message Id", topic, subscription);
+ }
cnx.sendGetLastMessageId(getLastIdCmd, requestId).thenAccept(cmd -> {
MessageIdData lastMessageId = cmd.getLastMessageId();
@@ -2384,8 +2386,10 @@ public class ConsumerImpl<T> extends ConsumerBase<T> implements ConnectionHandle
markDeletePosition = new MessageIdImpl(cmd.getConsumerMarkDeletePosition().getLedgerId(),
cmd.getConsumerMarkDeletePosition().getEntryId(), -1);
}
- log.info("[{}][{}] Successfully getLastMessageId {}:{}",
+ if (log.isDebugEnabled()) {
+ log.debug("[{}][{}] Successfully getLastMessageId {}:{}",
topic, subscription, lastMessageId.getLedgerId(), lastMessageId.getEntryId());
+ }
MessageId lastMsgId = lastMessageId.getBatchIndex() <= 0
? new MessageIdImpl(lastMessageId.getLedgerId(),
