You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by guanyq <dl...@163.com> on 2020/07/03 15:44:09 UTC

flink1.9读取阿里Mq问题

flink1.9读取阿里RocketMQ
如何设置AccessKey，SecretKey 参数


finalRMQConnectionConfigconnectionConfig=newRMQConnectionConfig.Builder().setHost("localhost").setPort(5000)....build();

Re: flink1.9读取阿里Mq问题

Posted by zhisheng <zh...@gmail.com>.

hi，guanyq

社区版本的 Flink 应该默认没有和 RocketMQ 连接的 Connector，在 RocketMQ 的社区项目中看到和 Flink 整合的模块：
https://github.com/apache/rocketmq-externals/tree/master/rocketmq-flink

你说的 AccessKey，SecretKey 参数应该是 ACL 权限校验，看了代码应该是不支持的，不过可以自己去进行扩展。

Best！
zhisheng

guanyq <dl...@163.com> 于2020年7月3日周五 下午11:44写道：

> flink1.9读取阿里RocketMQ
> 如何设置AccessKey，SecretKey 参数
>
>
>
> finalRMQConnectionConfigconnectionConfig=newRMQConnectionConfig.Builder().setHost("localhost").setPort(5000)....build();

回复：flink1.9读取阿里Mq问题

Posted by 李军 <ho...@163.com>.

        您好！
        自定义source继承RichSourceFuntion.open() 里去构建Conumer 可以设置AccessKey，SecretKey 参数；
        


2020-7-4
| |
李军
|
|
hold_lijun@163.com
|
签名由网易邮箱大师定制
在2020年7月3日 23:44，guanyq<dl...@163.com> 写道：
flink1.9读取阿里RocketMQ
如何设置AccessKey，SecretKey 参数


finalRMQConnectionConfigconnectionConfig=newRMQConnectionConfig.Builder().setHost("localhost").setPort(5000)....build();