apache/incubator-rocketmq

Features

• Distributed Messaging - Provides a scalable and fault-tolerant distributed messaging infrastructure designed for high-throughput cloud-native environments.
• Distributed Event Streaming Platforms - Acts as a high-throughput distributed event streaming platform for real-time data management and event-driven application building.
• High-Throughput Data Streaming - Handles continuous flows of high-throughput events for processing and distribution across cloud-native environments.
• Message Brokers - Functions as a distributed message broker ensuring reliable delivery of messages between producers and consumers.
• Primary-Replica Replication - Employs a primary-replica replication architecture to ensure high availability and fault tolerance across brokers.
• Real-Time Data Streaming - Provides a platform for processing and transforming continuous event streams in real-time to synchronize state and derive insights.
• Write-Ahead Logging - Utilizes a sequential write-ahead log for high-throughput message persistence and durable state recovery.
• Horizontal Scaling Strategies - Enables horizontal scaling of throughput and latency reduction through a distributed broker architecture.
• Real-Time Data Streams - Moves data between services in real time using messaging and streaming patterns for event-driven architectures.
• Message Routing - Decouples system components by transporting messages between producers and consumers in an event-driven architecture.
• Message Ordering Guarantees - Guarantees strict first-in-first-out delivery for messages within a specific queue to maintain data consistency.
• Transactional Message Coordination - Implements an atomicity mechanism that links message delivery directly to local transaction outcomes for critical operations.
• Transactional Messaging - Provides a transactional messaging system that ensures atomicity by linking message delivery to local transaction outcomes.
• Two-Phase Commit Protocols - Coordinates producers and brokers via a two-phase commit process to ensure atomic message delivery linked to local transactions.
• Event-Driven Architectures - Implements a reactive framework for building event-driven architectures by decoupling services via asynchronous message streaming.
• Event Middleware - Serves as a communication middleware layer that decouples services using pub-sub and request-reply patterns.
• Messaging Patterns - Supports decoupling services through publish/subscribe, request/reply, and streaming patterns.
• Partitioned - Implements partitioned queue structures to distribute workloads across multiple internal sub-queues for high-concurrency performance.
• Consumer Offset Trackers - Tracks consumer read progress using numerical offsets to enable reliable message replay and recovery.
• External Data Connectors - Ships a library of source and sink connectors for integrating with big-data ecosystems and external platforms.
• Pull-Based Consumers - Implements a pull-based consumer model that allows clients to fetch data at their own pace to prevent overwhelming slow consumers.
• Stream Computing Engines - Provides a lightweight engine that transforms events in real-time to derive immediate insights from continuous data flows.
• Production Cluster Deployers - Provides automated provisioning and lifecycle management for deploying production-grade messaging clusters.
• Kubernetes Orchestration - Offers native Kubernetes orchestration tools and charts for managing the lifecycle of messaging environments in container clusters.
• IoT Message Ingestion - Provides an MQTT broker specifically designed for ingesting and routing event data from mobile applications and hardware terminals.
• MQTT Message Brokers - Ships a specialized MQTT broker to process and ingest event data from hardware terminals and mobile devices.
• MQTT Messaging Integrations - Provides an MQTT broker to ingest and process event data from mobile applications and hardware terminals.
• Message Stream Replayers - Enables the retrieval and replay of previous events from a stream using timestamps or offsets to recover system state.
• Expression-Based Matchers - Provides logic engines that evaluate boolean expressions against message properties to determine server-side routing and delivery.
• Server-Side Message Filtering - Filters specific messages using expressions or tags to deliver only relevant data to intended consumers.
• System Event Routing - Streams data between internal and external systems to synchronize state or migrate information.
• Identity and Access Management - Integrates authentication and authorization mechanisms to restrict system access to authorized users.
• Network Encryption - Uses cryptographic functions to secure data transmissions between services, ensuring authentication and privacy.
• Administrative Consoles - Provides a visual administrative console for overseeing the messaging environment and performing maintenance tasks.
• Cluster Monitoring - Includes a centralized administrative dashboard for controlling configuration and monitoring cluster health.
• End-to-End Message Tracing - Tracks the lifecycle of messages using standard tracing protocols to identify system bottlenecks.
• Metric and Performance Monitors - Exports health and throughput metrics to external tools for operational status tracking.
• Messaging and Event Streaming - Low-latency and reliable message-oriented middleware.

Star history