Remove log unacked msg.
@@ -929,9 +929,6 @@ public class Consumer {
subscription.addUnAckedMessages(ackedMessages);
unackedMsgs = UNACKED_MESSAGES_UPDATER.addAndGet(consumer, ackedMessages);
}
- if (unackedMsgs < 0) {
- log.error("unackedMsgs is : {}, ackedMessages : {}, consumer : {}", unackedMsgs, ackedMessages, consumer);
- }
return unackedMsgs;
}
