未验证 提交 61f4f99b 编写于 作者: H Heng Du 提交者: GitHub

Merge pull request #1461 from RongtongJin/apache-develop

Fix(client): lite pull consumer lost messages in some scenario
......@@ -676,7 +676,6 @@ public class DefaultLitePullConsumerImpl implements MQConsumerInner {
offset = 0;
}
}
assignedMessageQueue.updateConsumeOffset(messageQueue, offset);
}
return offset;
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册