提交 bd0752ee 编写于 作者: J Jia Zhai 提交者: xiaolong.ran

Fix wrongly report "3600 messages have timed-out" (#5477)

related issue #5349

(cherry picked from commit 09360682)
上级 7914eb31
......@@ -129,7 +129,7 @@ public class UnAckedMessageTracker implements Closeable {
try {
ConcurrentOpenHashSet<MessageId> 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);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册