我正在尝试使用MongoDB
更改流使用Kafka
. 我选择 AWS MSK 是因为我的整个基础设施都在 AWS 内,而且很容易与其他 AWS 服务集成。
我在 VPC 中创建了一个 AWS MSK 集群,并使用mongodb Kafka connector创建了一个 AWS MSK 连接。我收到以下错误(异常打开套接字,连接超时)
为了测试它是否与 VPC 有关,我通过将 0.0.0.0 列入白名单来授予公众对 MongoDB 的访问权限,然后连接器工作正常。所以我相信它与VPC有关。
我多次尝试使用带有公共子网、NAT 网关等的 VPC 的 AWS MSK,但它仍然无法正常工作。我得到同样的错误。我相信 AWS MSK 连接器使用与 AWS MSK 相同的 VPC 配置,因为 AWS MSK Connect 没有单独的配置。