Apache RocketMQ
Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance, and reliability. It provides trillion-level message capacity with rich message types including normal, transactional, delayed, and ordered messages.
APIs
Apache RocketMQ
RocketMQ provides producer and consumer APIs with client SDKs in Java, Go, Python, C++, C#, Node.js, and Rust, along with a REST API and gRPC-based remoting for message operatio...
Capabilities
Features
Billion-level message throughput with low latency
Normal, ordered, delayed, transactional, and batch messages
Server-side tag and SQL expression filtering
Transactional messages for exactly-once delivery
Schedule messages with configurable delay levels
Automatic dead letter queue for failed messages
End-to-end message tracing for debugging and monitoring
Use Cases
Ensure ordered processing of e-commerce order events
Decouple microservices with reliable asynchronous messaging
Aggregate application logs from distributed services
Reliable transactional messaging for financial systems
Integrations
RocketMQ Spring Boot starter for easy integration
Flink connector for stream processing from RocketMQ
Spark Streaming connector for RocketMQ
RocketMQ Operator for Kubernetes-native deployment