##当前环境
EMQX: enterprise: 5.6.1 (跑在我的本地mac上)
Amazon Managed Service for kafka(MSK)
kafka版本2.6.0
网络:public access
认证方式:SASL_Scram
Brokers:<我的broker1>:9196,<我的broker2>:9196,<我的broker3>:9196
我自己本地MAC上测试 SASL_SCARM认证是没有问题的
我的目的
- 我想创建创建 emq sink connect,将iot的stream data打到 AWS MSK
- 于是我按照这个文档创建kafka生产者:将 MQTT 数据传输到 Apache Kafka | EMQX 文档
- 但是我创建连接器一直报错
我的问题现象
后端emqx进程报错和前端报错如图
你好,从报错的日志看是链接超时了。方便本地wireshark抓包么?看看 EMQX是否将链接请求发出去,然后 AWS 又是如何处理的?
抓包的时候,我只做了一种操作——“测试链接”
抓包的结果如下:
求教,如果想要通过Scram 认证方式连接MSK,你们是否有测试过,如果有的话,求个详细点的MSK配置步骤,以及EMQX的测试步骤,求个参考。
抓包结果在这里:
https://www.cloudshark.org/captures/2791d7a9baf5?filter=tcp.port%20%3D%3D%209196
您可以通过其他filter过滤查看(MSK的对外 public端口是9196, MSK三个ip地址是这个:
(ip.addr == 52.204.135.95 or ip.addr == 34.206.42.184 and ip.addr == 3.223.9.115)
你这个应该不是认证的问题:
我即使用的无认证模式连你的kafka,也是 connect timeout的。。
你试下用其它的 kafaka client (比如cli) 能连上么。
PS: 这个 wrieshark 的方式真不错,不过我也没看明白。
我们是有对应的测试用例的:https://github.com/emqx/emqx/blob/238c207b092802205e915f2f9f4a9c6a9a3ca8a5/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_impl_producer_SUITE.erl#L1149-L1152