rocketmq-flink
Message processor
Provides integration for RocketMQ with Apache Flink, enabling data streaming and messaging using the RocketMQ source and sink.
RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
142 stars
45 watching
96 forks
Language: Java
last commit: 6 months ago cloud-nativerocketmqstreaming
Related projects:
| Repository | Description | Stars |
|---|---|---|
| apache/rocketmq-site | The official documentation site for a cloud-native messaging and streaming platform | 57 |
| apache/rocketmq-streams | Provides a lightweight stream processing framework | 172 |
| apache/rocketmq-spring | A library that enables integration of RocketMQ with Spring Boot for messaging and event-driven programming | 2,111 |
| apache/rocketmq-clients | A collection of client libraries for Apache RocketMQ, providing standardized interfaces for various programming languages. | 327 |
| apache/rocketmq-connect | A tool for streaming data between Apache RocketMQ and other systems | 122 |
| apache/rocketmq-mqtt | An implementation of an MQTT protocol architecture model integrated with RocketMQ's message unified storage engine. | 183 |
| apache/rocketmq-client-nodejs | A lightweight Node.js wrapper around a C++ client for RocketMQ messaging system | 188 |
| apache/rocketmq-client-cpp | A C++ client for Apache RocketMQ, providing messaging and streaming capabilities. | 370 |
| apache/flink-connector-rabbitmq | A Flink connector for RabbitMQ message broker | 19 |
| apache/rocketmq-apis | Defines the API interface and payload message structure for RocketMQ using Protocol Buffers version 3. | 19 |
| apache/rocketmq-dashboard | A monitoring dashboard for Apache RocketMQ | 1,089 |
| apache/rocketmq-eventbridge | A messaging service that enables event-driven architectures and loosely coupled distributed systems | 137 |
| apache/rocketmq | A distributed messaging and streaming platform with low latency, high performance, and reliability. | 21,250 |
| apache/rocketmq-docker | Provides Docker images and scripts to deploy Apache RocketMQ clusters with various configurations | 683 |
| apache/rocketmq-operator | A Kubernetes operator for managing RocketMQ service instances | 316 |