カフカプロデューサを別のスレッドで使用する

Question

カフカにメッセージをプッシュするJavaベースのWebアプリケーション用のカフカプロデューサがあります。ドキュメントごとに私はkafkaプロデューサがスレッドセーフであることがわかりました。私はカフカのプロデューサーのインスタンスを1つ持ち、別のスレッド（ウェブリクエスト）で使用することができますが、それぞれが私のケースではプロデューサーを開いたり閉じることができますか？これによって問題が生じるのでしょうか？または、要求ごとにプロデューサを開始する方が良いですか？

Answer 1

はい、KafkaProducerはスレッドセーフです。
はClass KafkaProducer

カフカのクラスターにレコードを発行しカフカクライアントを参照してください。

プロデューサはスレッドセーフであり、一般にすべての スレッドで共有する必要があります。

プロデューサは、 も、 と通信する必要がある各ブローカへのTCP接続として、I/Oを行う単一のバックグラウンドスレッドを管理します。使用後にプロデューサを閉じないと、 リソースがリークします。

Answer 2

これは、アプリケーションの開始時に単一のインスタンスをインスタンス化し、すべてのスレッドで共有することです（これは、ステートフルなクライアントコネクタ（SQLクライアント、elasticsearchクライアントなど）の典型です）。アプリケーションのシャットダウン時にのみ閉じる必要があります。