apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
https://rocketmq.apache.org/
Apache License 2.0
21.26k stars 11.7k forks source link

#8509 lmq offset sync master to slave #8709

Open mongolhoo opened 2 months ago

mongolhoo commented 2 months ago

https://github.com/apache/rocketmq/issues/8509

Fixes #issue_id

Brief Description

How Did You Test This Change?

lizhanhui commented 2 months ago

This pull request does fix something that is broken. However, this is a design error to replicate bits here and there from one node to the other.

WAL should the the ONLY data structure that is replicated among nodes and it contains source of truth for everything, including offset advancement of each consumer that is managed in the sever side.

domyway commented 1 month ago

CR need

How is it going