opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2640 from areyouok/fix_resetOffset

Browse Source 
[ISSUE #2449]  fix: resetOffset simultaneously will cause each message consume more than once
This commit is contained in:
Heng Du
2021-01-28 00:48:48 +08:00
committed by GitHub
parent d8f88c51eb f8ac225411
commit b2223c99a1
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+1 -1
View File
@@ -1105,7 +1105,7 @@ public class MQClientInstance {
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;
try {
MQConsumerInner impl = this.consumerTable.get(group);