rocketmq-streams
Stream processor
Provides a lightweight stream processing framework
Apache rocketmq
172 stars
50 watching
82 forks
Language: Java
last commit: 5 months ago Related projects:
Repository | Description | Stars |
---|---|---|
| Provides integration for RocketMQ with Apache Flink, enabling data streaming and messaging using the RocketMQ source and sink. | 145 |
| The official documentation site for a cloud-native messaging and streaming platform | 57 |
| A library that enables integration of RocketMQ with Spring Boot for messaging and event-driven programming | 2,125 |
| A tool for streaming data between Apache RocketMQ and other systems | 122 |
| A collection of client bindings for Apache RocketMQ, providing cloud-native solutions for multiple programming languages. | 338 |
| A lightweight Node.js wrapper around a C++ client for RocketMQ messaging system | 188 |
| A C++ client for Apache RocketMQ, providing messaging and streaming capabilities. | 370 |
| End-to-end testing framework for Apache RocketMQ | 14 |
| An implementation of an MQTT protocol architecture model integrated with RocketMQ's message unified storage engine. | 183 |
| Defines the API interface and payload message structure for RocketMQ using Protocol Buffers version 3. | 20 |
| A Kubernetes operator for managing RocketMQ service instances | 316 |
| Extends Java 8 lambdas with additional functionality for working with sequential data streams | 2,092 |
| A monitoring dashboard for Apache RocketMQ | 1,104 |
| A Python client for Apache RocketMQ messaging system | 279 |
| A tool for exporting RocketMQ metrics to Prometheus for monitoring and analysis. | 297 |