search

apache / 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.
https://rocketmq.apache.org/
Apache License 2.0
139 stars 88 forks source link

Support rocketmq v5 client #80

Open lizhimins opened 1 year ago

lizhimins commented 1 year ago

RocketMQ v5 版本客户端底层协议使用 gRpc，规范了各种 api 的具体行为，可以基于新的版本客户端来实现一下 connector

wlazjr commented 1 year ago

I am very interested in this, can you give it to me?

lizhimins commented 1 year ago

Nice, welcome to develop together. Later, I will add some background knowledge about the implementation of rocketmq and flink