rocketmq icon indicating copy to clipboard operation
rocketmq copied to clipboard

[Feature] Support LMQ In RocksDB Mode

Open 1294566108 opened this issue 10 months ago • 0 comments

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?

1294566108 avatar Apr 10 '24 09:04 1294566108