librdkafka上のマルチスレッドプロデューサコンシューマアプリケーション

Question

複数のプロデューサがconfのshameコピーを共有できますか？ confの同じコピーを共有できない場合は、同じdr_cbを共有してもよろしいですか？

Answer 1

CのAPI（rd_kafka_new()、rd_kafka_topic_new()）が渡された.._conf_tオブジェクトの所有権を取得しますので、あなたが別のクライアントまたはトピックのためにそれを再利用したい場合は、最初のコピーを作成する.._conf_dup()機能を使用する必要があります。

C++ファクトリコンストラクタは、指定されたConfオブジェクトを自動的にコピーし、その所有権を取得しません。

マルチスレッドについても言及します。librdkafkaはスレッドセーフであり、複数のスレッドから同じプロデューサまたはコンシューマクライアントを使用できます。