Skip to content

Commit 32efd3e

Browse files
thetumbledthetumbled
andauthored
[improve][broker] add warn log when the delayedMessagesCount is incorrect. (#24460)
Co-authored-by: thetumbled <[email protected]>
1 parent 968eb52 commit 32efd3e

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -220,6 +220,10 @@ public NavigableSet<Position> getScheduledMessages(int maxMessages) {
220220
// Reset to initial state
221221
highestDeliveryTimeTracked = 0;
222222
messagesHaveFixedDelay = true;
223+
if (delayedMessagesCount.get() != 0) {
224+
log.warn("[{}] Delayed message tracker is empty, but delayedMessagesCount is {}",
225+
dispatcher.getName(), delayedMessagesCount.get());
226+
}
223227
}
224228

225229
updateTimer();

0 commit comments

Comments
 (0)