organization · inferred from evidence
confluentinc
The organization maintaining confluent-kafka-python and related libraries.
- 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
- Fix confluent-kafka build error: librdkafka/rdkafka.h file not found
Installing confluent-kafka from source failed with `fatal error: 'librdkafka/rdkafka.h' file not found` because the build needs the librdkafka C library headers first. Two options: install librdkafka before pip (`brew install librdkafka` on