apache-kafka - 使用 confluent-kafka-python 来自融合云代理的 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()