tool · inferred from evidence
consumer.poll
A method in confluent-kafka-python for polling messages.
- Fix confluent-kafka consume(timeout=1) taking longer than timeout
I expected `consume(100, timeout=1)` to return within a second; it took five. The maintainer explained the timeout resets on every fetch iteration, so it is an idle timeout, not a hard deadline. Upstream fixed the semantics in librdkafka PR