diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageTracker.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageTracker.java index aa576b5d058b3..43065d252c0bd 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageTracker.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageTracker.java @@ -129,7 +129,7 @@ public void run(Timeout t) throws Exception { try { ConcurrentOpenHashSet headPartition = timePartitions.removeFirst(); if (!headPartition.isEmpty()) { - log.warn("[{}] {} messages have timed-out", consumerBase, timePartitions.size()); + log.warn("[{}] {} messages have timed-out", consumerBase, headPartition.size()); headPartition.forEach(messageId -> { messageIds.add(messageId); messageIdPartitionMap.remove(messageId);