rocketmq-flink
by apache
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.
AI summary
Message processor
Provides integration for RocketMQ with Apache Flink, enabling data streaming and messaging using the RocketMQ source and sink.
- stars
- 145
- forks
- 96
- watching
- 45
Similar projects
Found by comparing what the projects do, not just their names.
Messaging platform
The official documentation site for a cloud-native messaging and streaming platform
Stream processor
Provides a lightweight stream processing framework
Messaging framework
A library that enables integration of RocketMQ with Spring Boot for messaging and event-driven programming
RocketMQ Client Libraries
A collection of client bindings for Apache RocketMQ, providing cloud-native solutions for multiple programming languages.
Data pipeline tool
A tool for streaming data between Apache RocketMQ and other systems
MQTT integration
An implementation of an MQTT protocol architecture model integrated with RocketMQ's message unified storage engine.
RocketMQ client
A lightweight Node.js wrapper around a C++ client for RocketMQ messaging system
RocketMQ Client
A C++ client for Apache RocketMQ, providing messaging and streaming capabilities.
RabbitMQ connector
A Flink connector for RabbitMQ message broker
API definition
Defines the API interface and payload message structure for RocketMQ using Protocol Buffers version 3.
RocketMQ monitor
A monitoring dashboard for Apache RocketMQ
Event bus
A messaging service that enables event-driven architectures and loosely coupled distributed systems
Messaging platform
A distributed messaging and streaming platform with low latency, high performance, and reliability.
RocketMQ docker deployer
Provides Docker images and scripts to deploy Apache RocketMQ clusters with various configurations
RocketMQ manager
A Kubernetes operator for managing RocketMQ service instances