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/client/rocketmq_consumer.go line 147

Describe the solution you'd like

Are you willing to submit PR?

• Yes I am willing to submit a PR!