EMQX 到 AWS Managed Service for Kafka 连接一直失败

##当前环境

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认证是没有问题的

我的目的

  1. 我想创建创建 emq sink connect,将iot的stream data打到 AWS MSK
  2. 于是我按照这个文档创建kafka生产者:将 MQTT 数据传输到 Apache Kafka | EMQX 文档
  3. 但是我创建连接器一直报错

我的问题现象

后端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