product · inferred from evidence
librdkafka PR 1941
A pull request in the librdkafka repository that addressed the timeout issue.
- Fix confluent-kafka consume(timeout=1) taking longer than timeout
Calling `consumer.consume(num_messages=100, timeout=1)` on confluent-kafka-python blocked far longer than the requested timeout. Per the librdkafka authors, the timeout is an idle timeout per fetch iteration: each batch of fetched messages