kafka-python
kafka-python copied to clipboard
dpkp
Python client for Apache Kafka
Hi, I have the problem, that my consuming app runs all the time but the producing app only runs like 3-4 hours a day. the result is, that, after all...
Doesn't seem to be explained in the docs, but it is mentioned. Same for TopicPartition. https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html
I needed to use kafka as backend message queue with the gevent web-socket, but it is not working, and giving error, i checked that kafka topics and brokers are working...
As confluent Kafka supports changing the log retention period, such features are currently unavailable in the Kafka-python library?
Is it possible to handle `NodeNotReadyError` internally? I want to catch the exception (is it an exception that can be exposed or it is handled internally by the lib?). I...
Hi everyone, When I was trying to manually commit the consumer offset, I got this InvalidCommitOffsetSizeError error, is anyone familiar with this error and can give me some hints, e.g....
Hello, I noticed some messages not being published to Kafka although the logs report no error, and it seems that if a message exceeds the maximum size (`max_request_size` in the...
Hello, im trying to reuse kafka instance but it fails when its used to send information to another topic that it is not the first Traceback: Traceback (most recent call...
On ticket #2404 it was mentioned that there are thoughts to start dropping support for EoL Python versions. However, is the a plan to support Python 3.9/3.10/3.11 versions?
Greetings, I see that the parameters are referring to the location of the key files. Is there a way to pass the key without writing it to disk?
