[feature] Support RocketMQ as async consumer backend

Is your feature request related to a problem? Please describe. When I tried to integrate async consumers with my existing messaging infrastructure, I found that RocketMQ is currently not supported. Since RocketMQ is a widely used message queue system in distributed applications, the lack of support makes it difficult to use this project together with RocketMQ-based architectures.

Describe the solution you'd like. I would like to request the addition of RocketMQ support as an async consumer backend.