confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== If we run the Kafka 6 Consumers in cluster with 6 pods in GCP, is there a way to track if any of pods goes down which makes...
Description =========== It seems like `avro-python3` was recently deprecated in favor of the base `avro` library according to the README below; however, `confluent-kafka` depends on `avro-python3`. https://github.com/apache/avro/tree/master/lang/py3 How to reproduce...
This resolves issue [#1303 ](https://github.com/confluentinc/confluent-kafka-python/issues/1303)
Description =========== I want to create a local kafka setup using docker-compose that replicates very closely the secured kafka setup in confluent cloud. The cluster I have in Confluent Cloud...
Description =========== I have below nested schema which is need to push my message to. **commom.avsc** which is register with subject `io.test.common.event.EventData`. ``` { "namespace": "io.test.common.event", "type": "record", "name": "EventData",...
Description =========== I'm trying to run a Kafka consumer using the confluent-kafka python package. I've been using this example : https://github.com/confluentinc/confluent-kafka-python/blob/master/examples/oauth_producer.py as reference. We have oauth setup. And this setup...
Description =========== The ProtobufDeserializer has got a member called `_msg_class`, which should point to a `google.protobuf.internal.GeneratedProtocolMessageType` The constructor of ProtobufDeserializer receives a GeneratedProtocolMessageType in the `message_type` argument, but instead of...
Description =========== Looking for kerberos authentication support for Schema Registry. For example, using the AvroProducer method the schema registry class doesn't support a schema registry instance with kerberos auth. Kafka...
Description =========== Versions: python 3.8.8 Does Confluent kafka python library support different registry? We plan to leverage the following registry https://www.apicur.io/registry/docs/apicurio-registry/2.0.0.Final/index.html https://developers.redhat.com/blog/2019/12/17/replacing-confluent-schema-registry-with-red-hat-integration-service-registry/ How to reproduce ================ Sample code: ``` class...
Description =========== Hey guys! I've seen this issue was opened a couple of times, but nothing worked in my scenario... When I try creating the consumer using SASL, I'm getting...
