私は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。0 の場合rkmessages_sizeは呼び出されません。
この場合、rk_repますます大きくなることがあります。
で stats_cb をトリガーする方法はConsumer_consume(0)? ありがとう