kafka-python
kafka-python copied to clipboard
dpkp
Python client for Apache Kafka
This issue has similarities with #1166 which has been fixed, however it represent on latest version(v2.0.2). ### Problem Shutdown kafka broker or drop all traffic to port 9092 ... and...
No release in 1.5 yrs. Just wondering if eventually changes on Kafka broker will become incompatible with what we have. Is the project dead?
We noticed a critical bug (or expected behavior, you will tell but this is totally not expected IMHO) with Kafka `poll()`. It's very easy to reproduce I believe. We initialize...
to fix callback may lost #2291, and chain_future parameter for kafka producer's send method --- This change is [](https://reviewable.io/reviews/dpkp/kafka-python/2292)
as we can see [future.py](https://github.com/dpkp/kafka-python/blob/master/kafka/future.py) has no locks, when we use kafka proudcer's method send and add callback, the callback may never called; when execute success, success callback are called...
This started happening last week. The client has not changed versions. The server has not changed versions. All of the builds are occurring in identical environments, for all intents and...
We're using `kafka-python` inside a Kubernetes container and the Kafka brokers are addressable via a service called `autossh` which proxies from the Kubernetes cluster to a Kafka deploy which is...
Try to compare these 2 sample below ``` if __name__ == '__main__': producer.send(topic, value=b'message') ``` ``` if __name__ == '__main__': while 1: producer.send(topic, value=b'message') time.sleep(2) ``` So once standalone the...
Wrong base class causes error when checking code with mypy: ``` kafka/protocol/admin.py:928: error: Class kafka.protocol.admin.DescribeClientQuotasResponse_v0 has abstract attributes "RESPONSE_TYPE" kafka/protocol/admin.py:928: note: If it is meant to be abstract, add 'abc.ABCMeta'...
When _api_version_ is not set in constructor of _KafkaClient_, _check_version_ [is called](https://github.com/dpkp/kafka-python/blob/f19e4238fb47ae2619f18731f0e0e9a3762cfa11/kafka/client_async.py#L244) with timeout of _api_version_auto_timeout_ms_. Then, one random node from _bootstrap_servers_ is [selected ](https://github.com/dpkp/kafka-python/blob/f19e4238fb47ae2619f18731f0e0e9a3762cfa11/kafka/client_async.py#L897) and a socket is opened,...
