我在 MSK 中创建了一个包含 2 个代理的集群,但我无法使用 kafkajs 客户端进行连接。我不断收到此连接超时错误
{"level":"ERROR","timestamp":"2021-07-29T13:35:35.625Z","logger":"kafkajs","message":"[Connection] 连接超时","broker": "{broker1}","clientId":"order-app"} {"level":"ERROR","timestamp":"2021-07-29T13:35:35.627Z","logger":"kafkajs", "message":"[BrokerPool] 连接种子代理失败,尝试列表中的另一个代理:连接超时","retryCount":0,"retryTime":251}
有关集群配置的更多信息,我使用了无访问控制方法并启用了 TLS 加密(纯文本不是)。我尝试了端口 9092 和 9094。我将入站规则设置为所有流量只是为了进行测试,但它似乎仍然超时。还尝试启用和禁用 ssl,但结果相同。
const { Kafka } = require('kafkajs')
const kafka = new Kafka({
clientId: 'order-app',
brokers: [
'broker1:port',
'broker2:port',
],
ssl: true,
})