Flink Steaming 消费 RocketMQ 数据
2025-01-08 本文已影响0人
你的样子999
版本
| 软件 | 版本 | 备注 |
|---|---|---|
| JDK | 1.8 | |
| Flink | 1.18.0 | |
| RocketMQ | 5.3.1 |
编译安装 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 功能未经测试，感兴趣的可以尝试。
