kafka-python
kafka-python copied to clipboard
dpkp
Python client for Apache Kafka
The admin client is missing listOffsets from the Java admin client: https://kafka.apache.org/30/javadoc/org/apache/kafka/clients/admin/Admin.html#listOffsets(java.util.Map)
kafka-python version: 2.0.1 python version: 3.7.7 This issue is a duplicate of #1842, that issue is closed and I cannot reopen it. Thus I opened new one. When I close...
We are running python Kafka producer clients in a serverless environment (AWS Lambda python3.8 runtime) whereby (as per recommended best practices) we are sharing long-lived producer connections across invocations. We...
Hello, **bug recurrence：** 1、**At first,** the kafka cluster running normally，and consumer was created at this time. kafka cluster: node id | node port 1 9092 2 9093 3 9094 consumer...
## Problem statement When enable_auto_commit=False, consumer.close(autocommit=False) and with no consumer.commit(), messages are not re-consumed when the program is restarted. It only works after we commit the offset to the topic...
What certificate file is the parameter `ssl_password` used for? The Apache client configuration has seperate parameters for keystore, truststore and the client key. Thanks
If you set connections_max_idle_ms to 0, the following code is used to configure the client: ```python class IdleConnectionManager(object): def __init__(self, connections_max_idle_ms): if connections_max_idle_ms > 0: self.connections_max_idle = connections_max_idle_ms / 1000...
Hello, I received a lot of logs, where I see that kafka-python try to describe every topic of the cluster, with Denied result. I don't know where this list come...
 When apply this code .When OSERROR occurs, it will be added to the system log, and its own log cannot be captured.  this try way cannot cache other...
Hi! Is there a way we can add ACLs and specify the --authorizer-properties + zookeeper values? `./kafka-acls.sh --authorizer-properties zookeeper.connect= --add --allow-principal User:someadmin --cluster` In [KafkaAdminClient](https://github.com/dpkp/kafka-python/blob/f0a57a6a20a3049dc43fbf7ad9eab9635bd2c0b0/kafka/admin/client.py#L35), I see an option to...
