librdkafka icon indicating copy to clipboard operation
librdkafka copied to clipboard

[KIP-714] Idle ratio calculation incorrect for non forwarded queues

Open emasab opened this issue 4 months ago • 0 comments

devel assert in rk->rk_ts_last_poll_end >= rk->rk_ts_last_poll_start fails in test 0056 because queues are forwarded. Poll ratio calculation should be per-queue instead of per-instance to handle the case where partition queues aren't forwarded to a single one, as happens instead with the high level consumer.

emasab avatar Jun 09 '25 17:06 emasab