python - Python confluent_kafka：消费（0）无法触发回调

Question

我正在使用confluent-kafka-python和librdkafka。

但我认为，confluent_kafka.Consumer.consume(0)不能触发stats_cb。

Consumer_consume(0) => rd_kafka_consume_batch_queue => rd_kafka_q_serve_rkmessages

中，在中rd_kafka_poll_cb被调用while (cnt < rkmessages_size) loop。如果rkmessages_size为 0，则不调用。

在这种情况下，rk_rep可能会变得越来越大。

如何触发 stats_cb in Consumer_consume(0)？谢谢

Answer 1

回调来自rd_kafka_q_serve_rkmessages()： https ://github.com/edenhill/librdkafka/blob/b50e247b77864c595569f7f7e9ec8dde63258210/src/rdkafka_queue.c#L574

如果您没有看到您的 stats_cb 被触发，请确保将statistics.interval.ms其设置为非零值。