apache-kafka - confluent-kafka-python を使用した confluent クラウド ブローカーからの ProduceResponse

Question

このログは、コンフルエント クラウドのプロデューサー クライアントのdebug=all構成で利用できます。confluent-kafka-python

を解析する方法ProduceResponseはrtt? on_deliveryコールバックを使用して実行できますか?

|RECV|rdkafka#producer-1| [thrd:sasl_ssl://b4-confluent-cloud-broker:9092/4]: sasl_ssl://b4-confluent-cloud-broker:9092/4: Received ProduceResponse (v7, 62 bytes, CorrId 31, rtt 323.28ms)

Answer 1

Message配信レポート コールバック内のオブジェクトには、ブローカーからの確認応答までlatency()の合計時間を返すメソッドがあります。produce()