kafka-python
kafka-python copied to clipboard
dpkp
Python client for Apache Kafka
Hello, I am a kafka-python rpm packager. I would like to fix "TypeError" in test/test_assignors.py using Python-3.11. The population of random.sample() must be a sequence and automatic conversion of sets...
**Summary** This PR introduces FNV1-a 32-bit hasher as a new partitioner. The tests confirmed that this implementation yields the same hash and partition selection as Goka/Sarama. **Why** Kafka leaves the...
If I use code that pauses and then resumes reading from partitions, the offset for the partition is set not to the last message read, but to the message far...
It'd be really nice to add support for `zstd` compression now that this is an officially supported codec ([KIP-110](https://cwiki.apache.org/confluence/display/KAFKA/KIP-110%3A+Add+Codec+for+ZStandard+Compression)).
When using GSSAPI SASL mechanism, connection errors are logged at INFO level, which is not enabled by default and misleading when it is enabled. This changes the level to ERROR...
Before working on #1063 we can implement the `enable_idempotence` option on Producer. Related KAFKA issue: [KAFKA-4817](https://issues.apache.org/jira/browse/KAFKA-4817). As it's already delivered and I want to finish both at the same time...
Hello, I am currently using version `2.0.2` to publish messages to an Amazon MSK broker version `2.3.1` but I am running into a wall when I get this exception (when...
Following this [issue from 2018](https://github.com/dpkp/kafka-python/issues/1632). It was closed but it seems to continue appearing in v2.0.1 Any idea what is happening here? > Exception ignored in: Traceback (most recent call...
I am working with kafka-python. I would like to fetch big amount data from kafka topic till its empty. Then do some action. Then start consuming online new events from...
