confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Method to fetch specific offsets (start to end) from a specific partition of a topic.
The current `AvroSerializer` (`src/confluent_kafka/schema_registry/avro.py`) and `JSONSerializer` (`src/confluent_kafka/schema_registry/json_schema.py`) classes do not override the schema when `use.latest.schema` is set to `True`, it currently only returns the `schema_id`. This PR is to address...
Added a delete records api and created integration tests and unit tests for the same
Description =========== This is an enhancement request to make it easier to write tests for user code that uses this client library. In unit tests, it would useful to be...
Hey I faced with a weird behaviour, and will be very appreciate for any hints why it may happened! Description =========== After updating `confluent-kafka` from `2.0.2` to `2.1.0`, I noticed...
Description =========== when trying to commit a message after not polling for anything more than the max.poll.interval.ms, I'm getting a non-recoverable segmentation fault that I can't handle in an exception...
Description I am using 3.8-alpine image to create docker container and trying to install librdkafka and confluent-kafka libraries but getting error while installing confluent-kafka error: command 'gcc' failed with exit...
Description =========== After upgrading kafka client to connect using SSL, which gets terminated by a haproxy, we see kafka client keeps disconnecting every 10 seconds. There is no loss to...
Description =========== When I try to use the Python 3.8 binary wheel on RHEL 8 and instantiate a `confluent_kafka.Producer` instance using SSL, I get a segmentation fault. How to reproduce...
Description =========== I have created a layer with confluent_kafka-2.0.2 in lambda function. when I simply run it, I get error at import statement.  Code :  Attached Zip file...
