提交 f8ac2254 编写于 作者: H huangli

[ISSUE #2449] resetOffset simultaneously will cause each message consume more than once.

上级 d8f88c51
...@@ -1105,7 +1105,7 @@ public class MQClientInstance { ...@@ -1105,7 +1105,7 @@ public class MQClientInstance {
return null; return null;
} }
public void resetOffset(String topic, String group, Map<MessageQueue, Long> offsetTable) { public synchronized void resetOffset(String topic, String group, Map<MessageQueue, Long> offsetTable) {
DefaultMQPushConsumerImpl consumer = null; DefaultMQPushConsumerImpl consumer = null;
try { try {
MQConsumerInner impl = this.consumerTable.get(group); MQConsumerInner impl = this.consumerTable.get(group);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册