Fix confusing logs (apache#13017)

fxbing · Dec 19, 2021 · f7b05ea · f7b05ea
1 parent 68b434e
commit f7b05ea
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -129,7 +129,7 @@ public void run(Timeout t) throws Exception {
                 try {
                     ConcurrentOpenHashSet<MessageId> headPartition = timePartitions.removeFirst();
                     if (!headPartition.isEmpty()) {
-                        log.warn("[{}] {} messages have timed-out", consumerBase, headPartition.size());
+                        log.info("[{}] {} messages will be re-delivered", consumerBase, headPartition.size());
                         headPartition.forEach(messageId -> {
                             addChunkedMessageIdsAndRemoveFromSequenceMap(messageId, messageIds, consumerBase);
                             messageIds.add(messageId);