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

Can support AliCloud RocketMQ #15

Closed yangmingjie closed 2 years ago

yangmingjie commented 2 years ago

我们是用的flink sql 做数据开发， 期待大佬回复。

duhenglucky commented 2 years ago

可以的，配置一下aksk 就可以了

kongslove commented 2 years ago

@duhenglucky 是否支持flink1.12.x版本

yangmingjie commented 2 years ago

可以的，配置一下aksk 就可以了

image

vongosling commented 2 years ago

@duhenglucky @SteNicholas Do we provide config addresses in cloud products. IMO, It would be better to provide this info in the cloud product's wiki, not here.

yangmingjie commented 2 years ago

@duhenglucky @SteNicholas Do we provide config addresses in cloud products. IMO, It would be better to provide this info in the cloud product's wiki, not here.

大神，我是用的flink sql 开发的就像上面的截图，这个怎么配置？

lizhimins commented 2 years ago

旧版本 org.apache.rocketmq.flink.legacy.example.RocketMQFlinkExample 新版本 org.apache.rocketmq.flink.source.RocketMQSource#createReader