We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 461a9a6 commit 12cbb18Copy full SHA for 12cbb18
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java
@@ -670,8 +670,8 @@ public void updateMessageTTL(int messageTTLInSeconds) {
670
671
@Override
672
public boolean expireMessages(int messageTTLInSeconds) {
673
- if ((cursor.getNumberOfEntriesInBacklog(false) == 0)
674
- || (cursor.getNumberOfEntriesInBacklog(false) < MINIMUM_BACKLOG_FOR_EXPIRY_CHECK
+ long backlog = cursor.getNumberOfEntriesInBacklog(false);
+ if ((backlog == 0) || (backlog < MINIMUM_BACKLOG_FOR_EXPIRY_CHECK
675
&& !topic.isOldestMessageExpired(cursor, messageTTLInSeconds))) {
676
// don't do anything for almost caught-up connected subscriptions
677
return false;
0 commit comments