mirror of
https://github.com/apache/rocketmq.git
synced 2026-10-30 18:44:38 +08:00
Fix(client):fix the issue that lite pull consumer lost messages in some scenario
In jepsen test, consumer lost messages when using the lite pull consumer. This is due to the incorrect setting of consume offset. Delete the wrong code to make it correct.
This commit is contained in:
-1
@@ -676,7 +676,6 @@ public class DefaultLitePullConsumerImpl implements MQConsumerInner {
|
||||
offset = 0;
|
||||
}
|
||||
}
|
||||
assignedMessageQueue.updateConsumeOffset(messageQueue, offset);
|
||||
}
|
||||
return offset;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user