confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Implemented for RegisteredSchema the method __str__, to return the schema as str when the schema is parsed to str().
Description Can't pickle KafkaException, wrong import. When i use celery, and celery use pickle to serialization, i get this error: ''PicklingError("Can\'t pickle : import of module \'cimpl\' failed")'' How to...
Description =========== The consumer subscribes to a topic in the following fashion ``` def setup_consumer(topic_list): try: consumer = Consumer( , 'auto.offset.reset':'earliest', 'fetch.min.bytes': '200000', } ) consumer.subscribe(topic_list) except Exception as e:...
Description =========== I'm installing the package in a python 3.9 docker image using pip and is throwing this below error, ``` [pipenv.exceptions.InstallError]: Failed to build confluent-kafka [pipenv.exceptions.InstallError]: error: subprocess-exited-with-error [pipenv.exceptions.InstallError]:...
Description =========== `Consumer.poll` client is going into infinite loop when the Kafka is running on Kubernetes. When the cluster is scheduled on the new node is just stuck on the...
Continuation of https://github.com/confluentinc/confluent-kafka-python/pull/1593 as the owner of the PR left the org.
Description =========== When Python 3.11 and Python3.12 came out, it took some time before `confluent_kafka` was compatible. Python 3.13 is supposed to drop on [October 1st](https://peps.python.org/pep-0719/), 2024, about 3 months...
- Fixed `logger` not working when provided as an argument to `AdminClient` - Updated `examples/adminapi.py` to include usage of the custom logger with `AdminClient`
Description =========== I am getting the following crash in very specific conditions, while the Python GC is running. I can reliably reproduce it in a pytest test suite of an...
Description =========== We have use case where we need to manually calculate partition ID using the murmur2 partitioner from the librdkafka. Rationale: we need to verify that messages received belongs...
