apache/rocketmq

This system is a distributed message middleware platform that manages the lifecycle of message producers, consumers, and brokers. It provides a comprehensive messaging engine supporting features such as transactional messages, ordered consumption, and message filtering, while ensuring high availability through controller-managed broker replication and automatic failover. The architecture includes a proxy layer for protocol translation and a robust authentication and authorization framework that supports both legacy and modern access control models.

This period focused on a comprehensive architectural overhaul of the broker, introducing a plugin-based request processing model, advanced cold-read strategies, and robust client management. The team also expanded the system's capabilities by implementing SQL92 message filtering, OpenMessaging compatibility, and Lite Topic support, while simultaneously establishing a multi-module Maven structure and Bazel build system.

69 changes

This period focused on expanding the proxy and controller modules with comprehensive gRPC v2 support, a pluggable service architecture, and observability features. It also introduced a new BrokerContainer for multi-broker management and enhanced transactional message handling with detailed metrics tracking.

83 changes

This period focused on a comprehensive overhaul of the security and storage infrastructure, introducing a pluggable authentication and authorization framework (ACL 2.0) alongside a new tiered storage module for message offloading. Concurrently, the codebase expanded its proxy capabilities with gRPC v2 support and implemented a RocksDB-backed configuration and state management system for the broker.

39 changes

apache/rocketmq was measured the same way every project in this corpus was: the same rubric, at a pinned commit, with the result published in full. Point the surveyor at a repository you know and see whether you agree with it.