Search before asking

• I had searched in the issues and found no similar issues.

Enhancement Request

This issue is a subproject issue of eventmesh. the subproject address is:
https://github.com/apache/eventmesh-go

located at:
eventmesh-go/plugin/connector/rocketmq/convert/rocketmq_message_reader.go line 53,55,58,61

Describe the solution you'd like

Are you willing to submit PR?

• Yes I am willing to submit a PR!