您好!
自定义source继承RichSourceFuntion.open() 里去构建Conumer 可以设置AccessKey,SecretKey
参数;
2020-7-4
| |
李军
|
|
hold_li...@163.com
|
签名由网易邮箱大师定制
在2020年7月3日 23:44,guanyq 写道:
flink1.9读取阿里RocketMQ
如何设置AccessKey,SecretKey 参数
hi,guanyq
社区版本的 Flink 应该默认没有和 RocketMQ 连接的 Connector,在 RocketMQ 的社区项目中看到和 Flink 整合的模块:
https://github.com/apache/rocketmq-externals/tree/master/rocketmq-flink
你说的 AccessKey,SecretKey 参数应该是 ACL 权限校验,看了代码应该是不支持的,不过可以自己去进行扩展。
Best!
zhisheng
guanyq 于2020年7月3日周五 下午11:44写道:
> flink1.9读取阿里RocketMQ
flink1.9读取阿里RocketMQ
如何设置AccessKey,SecretKey 参数
finalRMQConnectionConfigconnectionConfig=newRMQConnectionConfig.Builder().setHost("localhost").setPort(5000)build();