{"repo":"apache/rocketmq-flink","free":true,"listed":false,"github":"https://github.com/apache/rocketmq-flink","clone":"git clone https://github.com/apache/rocketmq-flink.git","description":"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.","language":"Java","stars":173,"topics":["cloud-native","rocketmq","streaming"],"license":"Apache-2.0","category":"databases-storage","readme_excerpt":"Apache Flink RocketMQ Connector This repository contains the Apache Flink RocketMQ connector. It provides Flink sources and sinks that read from and write to Apache RocketMQ, for both the DataStream API and the Table/SQL API. Two connector tracks are shipped: Track Module RocketMQ client Best for --- --- --- --- Remoting flink-connector-rocketmq rocketmq-client (remoting protocol) Classic topics, FLIP-27 source + SinkV2 sink, SQL gRPC flink-connector-rocketmq-grpc rocketmq-client-java (gRPC protocol) RocketMQ 5.x lite topics, downstream ack / fair throttling The SQL fat-jars are packaged by flink-sql-connector-rocketmq and flink-sql-connector-rocketmq-grpc . Apache Flink Apache Flink is an open source stream processing framework with powerful stream- and batch-processing capabilities. Learn more about Flink at https://flink.apache.org/ Apache RocketMQ Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications. Learn more about RocketMQ at https://rocketmq.apache.org/ Building the Apache Flink RocketMQ Connector from Source Prerequisites: Unix-like environment (we use Linux, Mac OS X) Git Maven (we recommend version 3.8.6) Java 11 The resulting jars can be found in the target directory of the respective module. Before opening a pull request, format the code and run the tests: Quick Start DataStream source & sink (remoting) SQL gRPC lite consumer (RocketMQ 5.x) The gRPC source emits AckableMessage and never acks by it","default_branch":null,"files":null,"tree":[],"storefront":"/r/apache","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/apache/rocketmq-flink/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}