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
141 stars 89 forks source link

How to create a flink table(flink sql) link to aliyun RocketMQ sevice with AccessKey ID and AccessKey Secret? #20

Closed yangmingjie closed 2 years ago

yangmingjie commented 2 years ago

image

yangmingjie commented 2 years ago

The demand is urgent，thanks a lot

SteNicholas commented 2 years ago

@yangmingjie , current version doesn't support the ack. I'm adding the ack to the table option. If you are agent, please add the wechat: 834031959 to discuss.

kaori-seasons commented 2 years ago

@yangmingjie, 当前版本不支持 ack。我正在将 ack 添加到 table 选项。如果您是代理，请加微信：834031959进行讨论。

If you support it, I plan to implement an example based on APIs such as DynamicTableSourceFactory DynamicTableFactory TableScanSource

lizhimins commented 2 years ago

We only need add the aclhook of rocketmq when constructing the producer and consumer, then add the parameter configuration in the SQL

GOODBOY008 commented 2 years ago

@SteNicholas I'm very interested in this,please assign the issue to me.

GOODBOY008 commented 2 years ago

Hi @duhenglucky ,This issue had supported by pr https://github.com/apache/rocketmq-flink/pull/45 .