0

MSK で 2 つのブローカーを持つクラスターを作成しましたが、kafkajs クライアントを使用して接続できません。この接続タイムアウトエラーが発生し続けます

{"level":"ERROR","timestamp":"2021-07-29T13:35:35.625Z","logger":"kafkajs","message":"[接続] 接続タイムアウト","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