Flink Steaming 消费 RocketMQ 数据

版本

编译安装 rocketmq-flink-connector

git clone git@github.com:chncaesar/rocketMQ-flink-connector.git

master 分支代码适配 flink-1.15.0，zjc 分支升级至 flink-1.18.0。请切换至 zjc 分支，执行 mvn install -DskipTests 安装至本机。

编写 Flink Streaming Java 代码消费

pom.xml 引入 rocket-flink-connector

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-flink</artifactId>
    <version>1.18.0</version>
</dependency>

<meta charset="utf-8">

参考 例子 编写代码。FlinkSQL 消费 RocketMQ 功能未经测试，感兴趣的可以尝试。