-
Notifications
You must be signed in to change notification settings - Fork 12k
Prepare to release Apache RocketMQ 5.5.0 #10238
Description
Summary
RocketMQ 5.5.0 brings Lite Mode, a lightweight subscription mechanism designed for AI scenarios, alongside enhancements across Broker, Proxy, and client components.
✨ Lite Mode (New Feature)
Introduced a lightweight subscription mode (Lite Mode) that delivers more efficient messaging with reduced resource consumption. This mode provides complete lifecycle management, event dispatching, subscription registration, message processing, and metrics monitoring. With the newly added Lite message processor, long-polling service, control handler, and corresponding protocol support, it establishes an efficient lightweight message subscription mechanism tailored for AI scenarios.
🔧 Broker Improvements
Extended the capabilities of core message processors including AckMessageProcessor, NotificationProcessor, PullMessageProcessor, and PopLiteMessageProcessor, while enhancing PopConsumerService and the consumer lock service. On the storage side, optimized the RocksDB implementations for RocksDBConsumerOffsetManager, ConsumerOffsetManager, and transactional messages, and improved CommitLog and other storage components along with the metrics capabilities of BrokerMetricsManager. Additionally, new configuration options have been added to BrokerConfig, with further extensions to TopicConfig, TopicAttributes, and other configuration classes.
🔧 Proxy Improvements
Expanded gRPC v2 protocol support with newly added activity classes and converters. Enhanced the processing capabilities of MessagingProcessor, ConsumerProcessor, and related processors. Introduced a message queue priority provider and penalty mechanism to further refine routing strategies.
🔧 Client Improvements
Extended the interfaces of MQClientAPIImpl and MQClientAPIExt, strengthened the load balancing logic in RebalanceImpl and MQClientInstance, and delivered optimizations to the delay strategy.
📝 Other Changes
Updated TLS configuration documentation in both Chinese and English. Removed deprecated GitHub workflow files. Expanded test coverage and resolved multiple known test case issues.
✨ Lite 模式(全新特性)
新增轻量级订阅模式(Lite Mode),在降低资源消耗的同时提供更高效的消息传递能力。该模式涵盖完整的生命周期管理、事件分发、订阅注册、消息处理及度量监控,并通过新增的 Lite 消息处理器、长轮询服务、控制处理器及相应协议支持,构建起高效的轻量级 AI 场景下消息订阅机制。
🔧 Broker 组件改进
扩展了 AckMessageProcessor、NotificationProcessor、PullMessageProcessor、PopLiteMessageProcessor 等核心处理器的功能,增强了 PopConsumerService 与消费者锁定服务;在存储层面,优化了 RocksDBConsumerOffsetManager、ConsumerOffsetManager 及事务消息的 RocksDB 存储实现,并对 CommitLog 等存储组件及 BrokerMetricsManager 的度量能力进行了改进;此外,在 BrokerConfig 中新增了若干配置项,并对 TopicConfig、TopicAttributes 等配置类进行了扩展。
🔧 Proxy 组件改进
扩展了 gRPC v2 协议支持,新增相关活动类与转换器;增强了 MessagingProcessor、ConsumerProcessor 等处理器的处理能力;并引入消息队列优先级提供者与惩罚机制,进一步完善了路由策略。
🔧 客户端改进
扩展了 MQClientAPIImpl 与 MQClientAPIExt 的接口功能,增强了 RebalanceImpl 和 MQClientInstance 的负载均衡逻辑,并对延迟策略进行了优化改进。
📝 其他变更
更新了中英文版本的 TLS 配置文档,移除了部分废弃的 GitHub 工作流文件,并扩展了测试覆盖范围,修复了多个已知测试用例问题。
Motivation
Prepare to release Apache RocketMQ 5.5.0
Describe the Solution You'd Like
Prepare to release Apache RocketMQ 5.5.0
Describe Alternatives You've Considered
Prepare to release Apache RocketMQ 5.5.0
Additional Context
No response