rocketmq
rocketmq copied to clipboard
[Feature] Support LMQ In RocksDB Mode
Is Your Feature Request Related to a Problem?
Rocketmq currently supports Lmq and Rocksdb respectively, but when Lmq and Rocksdb are enabled at the same time, consumption failure will occur. The reason is that there is no additional ConsumeQueue and ConsumeQueueOffset construction for lmq's multi-level topic in rocksdb mode. For the above situation, we can support opening Lmq and Rocksdb at the same time
Describe the Solution You'd Like
When Rocksdb mode is turned on, for each DispatchRequest, whether it is batch processing or single request processing, we need to perform additional Lmq processing logic, including but not limited to building ConsumeQueue and Offset、updating the maximum ConsumeQueueOffset, etc.
Describe Alternatives You've Considered
At present, I have implemented the first version of development. Can I provide it to the community?