rocketmq-flink

Cloud-Native Open Source

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.

★ 174 Stars ⑂ 104 Forks License: Apache License 2.0

Download Latest Release Official Website ↗ GitHub Repository ↗

About rocketmq-flink

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.

Supported Platforms

Open Source Web Cross-Platform

Related in Cloud-Native

tidb

TiDB is built for agentic workloads that grow unpredictably, with ACID guarantees and native support for transactions, analytics, and vector search. No data silos. No noisy neighbors. No infrastructur

harbor

An open source trusted cloud native registry project that stores, signs, and scans content.

spring-cloud-alibaba

Spring Cloud Alibaba provides a one-stop solution for application development for the distributed solutions of Alibaba middleware.

kratos

Your ultimate Go microservices framework for the cloud-native era.

TDengine

High-performance, scalable time-series database designed for Industrial IoT (IIoT) scenarios

Sentinel

A powerful flow control component enabling reliability, resilience and monitoring for microservices. (面向云原生微服务的高可用流控防护组件)