0

我在 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] 连接种子代理失败,尝试列表中的另一个代理:连接超时","re​​tryCount":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,
})
4

0 回答 0