confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== I have a pytest suite that will: 1. Create a kafka testcontainer as a module fixture 2. Create a bunch of topics as a module fixture using the...
Hi! Having this [place in code](https://github.com/confluentinc/confluent-kafka-python/blob/c32d69dfbc61100ac03117573e46fd28a3ac6965/src/confluent_kafka/avro/serializer/message_serializer.py#L104) as a problem for integration a new service in python with other services, that use other libs for kafka with schema registry logic without...
Description =========== Errors while installing latest version (2.5.0). ``` /mnt/tmp/pip-install-blxssofn/confluent-kafka/src/confluent_kafka/src/confluent_kafka.h:18:10: fatal error: Python.h: No such file or directory #include ``` confluent-kafka version: 2.5.0 OS: Amazon Linux 2023 How to reproduce...
Description =========== This issue is the same as #1581. With `confluent_kafka >2` a simple script to produce kafka message experiences a 1s delay when calling `Producer.flush` the first time after...
Works to build with https://github.com/confluentinc/librdkafka/pull/4803 As librdkafka in this case is installed in `/usr/local/lib` the build and install is done using ```shell C_INCLUDE_PATH=/usr/local/lib LIBRARY_PATH=/usr/local/lib LD_LIBRARY_PATH=/usr/local/lib python setup.py build C_INCLUDE_PATH=/usr/local/lib LIBRARY_PATH=/usr/local/lib...
Description =========== Hi Everyone! I am encountering an error when trying to produce messages to a kafka topic using the producer code from the getting-started tutorial and even with the...
Description =========== I'm producing some messages in our Kafka server, but getting acknowledgement of message delivery(_produccer.flush()_) is taking a huge time. That's why I added timeout of 1 second. But...
Description =========== When a topic is destroyed, but recreated quickly enough, confluent kafka seems to a) believe that the topic is healthy but b) not be able to consume any...
Description =========== When trying to build my project with pybuilder, the unittest stage of my jenkins pipeline fails with: ``` BUILD FAILED - PicklingError: Can't pickle : import of module...
