我正在使用融合的kafka python和librdkafka。
但我认为，合流的\u kafka.consumer.consume（0）不能触发stats\u cb。
消费者消费（0）=>rd\u kafka消费\u批量\u队列=>rd\u kafka\u q\u服务\u
在， rd_kafka_poll_cb 被称为 while (cnt < rkmessages_size) loop . 如果 rkmessages_size 为0，则不调用。
在这种情况下， rk_rep 可能变得越来越大。
如何在中触发stats\u cb Consumer_consume(0) ? 谢谢
1条答案
按热度按时间zlhcx6iw1#
回拨服务来自
rd_kafka_q_serve_rkmessages(): https://github.com/edenhill/librdkafka/blob/b50e247b77864c595569f7f7e9ec8dde63258210/src/rdkafka_queue.c#l574如果你没有看到你的状态被触发，确保
statistics.interval.ms设置为非零值。