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.25k stars 11.7k forks source link

[Bug] DLedger doesn't support LMQ #8927

Open bxfjb opened 3 days ago

bxfjb commented 3 days ago

Before Creating the Bug Report

Runtime platform environment

any

RocketMQ version

develop

JDK Version

any

Describe the Bug

Lmq msg's queueOffset field is set to 0 wrongly. Easy to reproduce. Actually I found following codes in MessageExtEncoder.java: image But the latter update of queueOffset was not found.

Steps to Reproduce

Run a broker under latest develop version. Send msgs and set Lmq related properties. The queueOffset of these msgs is zero.

What Did You Expect to See?

Correct queueOffset.

What Did You See Instead?

Zero queueOffset.

Additional Context

No response

bxfjb commented 2 days ago

I found the update code in CommitLog.java 9ead6580-b904-4d8b-9904-ba640b3d8948 But it seems that DLedgerCommitLog doesn't support LMQ for now, I'll change this issue's title and commit another pr later.