diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java index 0f34e0823d481..21ef9b38dbed9 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java @@ -115,10 +115,11 @@ public PersistentAcknowledgmentsGroupingTracker(ConsumerImpl consumer, Consum */ @Override public boolean isDuplicate(@NonNull MessageId messageId) { - if (lastCumulativeAck.messageId == null) { + final MessageId messageIdOfLastAck = lastCumulativeAck.messageId; + if (messageIdOfLastAck == null) { return false; } - if (messageId.compareTo(lastCumulativeAck.messageId) <= 0) { + if (messageId.compareTo(messageIdOfLastAck) <= 0) { // Already included in a cumulative ack return true; } else {