使用confluent -kafka- ProduceResponse来自confluent cloud broker的python

Question

此日志可通过confluent-kafka-python producer client for confluent cloud中的debug=all配置获得。

如何解析rtt的ProduceResponse？可以使用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()到代理确认的总时间。