[Feature] Integrate Apache RocketMQ 5.5.0 LiteTopic for AI Agent Asynchronous Communication

[qqeasonchen]

Search before asking

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

Feature Request

With the release of Apache RocketMQ 5.5.0, the new LiteTopic model provides native support for AI Agent communication scenarios, addressing three critical requirements:

1. Massive Session Channels: Supports 1M+ lightweight topics coexisting
2. State Persistence: Broker-side offset storage for session recovery
3. Event-Driven Scheduling: Ready Set mechanism reduces ineffective scanning by pre-filtering idle topics, cutting CPU overhead by 30%.

This integration will enable our multi-agent system to handle asynchronous task distribution and result collection efficiently.

Expected Outcomes:
☑ 50% reduction in Agent communication latency
☑ 100% session recovery after node failures
☑ 10x throughput improvement for 100K+ concurrent topics
☑ Native compatibility with MCP/ADK protocols

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct *