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 李军 <ho...@163.com> on 2020/07/04 04:12:38 UTC

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

        您好！
        自定义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();