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

李军 Fri, 03 Jul 2020 21:13:09 -0700

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



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


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