confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
I encountered a case where while I was reading through a topic, the topic was deleted and then created from the beginning. My consumer using `confluent_kafka` looks somewhat like this:...
Currently, SchemaRegistryClient does not allow to pass ssl.key.password as an argument - can we allow to pass this argument?
Description =========== We are using this library based consumer (basic one) to consume messages from MSK. performance wise, this doesnt meet our defined requirements. Can anyone suggest any pointers on...
Description =========== When the list_offsets() method of the AdminClient is invoked for multiple times, memory leakage occurs and the memory usage keeps increasing.    How to reproduce ================...
Description =========== Hi, I'm publishing messages on about 8000 topics using confluent kafka python producer. The cluster is a five node setup. After sometime I observed below timeout messages in...
Description =========== We run schema registry 5.1.4 (`confluentinc/cp-schema-registry:5.1.4`), which returns 422 when registering schemas using the latest confluent-kafka version, `2.6.2`. The culprit is PR #1852, specifically [these lines](https://github.com/confluentinc/confluent-kafka-python/pull/1852/files#diff-43c20e9f973c36e743655d731435321c8a4a62b823e2aef909a54c8f9ad6ea85R1638-R1648): they are...
as new protocol configuration can be put in configuration properties file What ---- Checklist ------------------ - [ ] Contains customer facing changes? Including API/behavior changes - [ ] Did you...
soak tests can now run on k8s with different test ids corresponding to different clusters What ---- Checklist ------------------ - [ ] Contains customer facing changes? Including API/behavior changes -...
Description =========== Hi i have a Schema registry server running with the following `server.properties` ```yaml # # Copyright 2018 Confluent Inc. # # Licensed under the Apache License, Version 2.0...
