問題タブ [kafka-node]

MSK トピックのプロデューサーとして機能する Lambda を AWS で作成しようとしています。すべての AWS ドキュメントは新しい EC2 インスタンスを作成するように言っていますが、私の Lambda は同じ VPC にあるので、これでうまくいくはずです。私はこれに非常に慣れておらず、ログステートメントがプロデューサー.on関数にヒットしないことに気付きました。nodejs と kafka-node モジュールを使用しています。コードは以下にあります。

基本的に、誰かがこれを行う方法を知っているかどうか、そしてラムダを介してテストを実行したときにプロデューサー.オン関数がヒットしないのはなぜだろうか? これは、送信できるかどうかを確認するためのテスト コードにすぎませんが、さらにデータが必要な場合は、お知らせください。事前に感謝します。

アプリケーションを Kafka と統合するために kafka-node を使用しようとしています。プラグイン サイトからサンプル コードを取得し、モジュール化してみました。バックグラウンドでコンフルエントな Kafka docker イメージを使用しています。

サンプルコード:

一方、次のコードを使用してこれにアクセスします

メッセージが Kafka トピックに書き込まれているため、すべてが正常に機能しているようです。唯一の問題は、しばらくすると次のエラーが表示されることです。

これを修正しようとしている間にnodejsの知識が完全に使い果たされたため、私は完全に途方に暮れています（これはそれほどではありません）。