confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== I'm looking to use a single Kafka producer for two slightly differnt use cases/message types. One that is just fire-and-forget and that will simply enqueue a message without...
Failed to load OpenSSL provider "legacy": error:07880025:common libcrypto routines::reason(524325)
Description =========== I tried to create Kafka producer and got some exceptions. Firstly I didn't use 'ssl.providers': 'default,legacy' in kafka_config and got: ```cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to create producer: Failed to parse...
fixes #1562 This pr expand named schema fully to their true schemas to fix "UnknownType" error when using avro union schema like below. ```json [ "confluent.io.examples.serialization.avro.User", "confluent.io.examples.serialization.avro.Award" ] ```
Description =========== Since confluent-kafka 2.1.0, subscribing to a non-existent topic causes python to segfault. How to reproduce ================ Using the files [in this gist](https://gist.github.com/ffissore/8328f58bba9aec4edb3387aac0aaa8ed), run docker compose, then run script...
Description =========== Currently the code in the schema_registry serdes to write the schemaId into the payload is duplicated across the three supported serdes (avro, protobuf, and json) and also hardcoded...
Add support for custom wireformat for serialized messages using a schema registry. resolves #1688
Description =========== Hello! I need some help about identfying and apply a solution about a strange behaviour that appear recently in our Kafka. We are using python confluent-kafka for several...
Description =========== [KIP-412](https://cwiki.apache.org/confluence/display/KAFKA/KIP-412%3A+Extend+Admin+API+to+support+dynamic+application+log+levels) added support for dynamic logs levels. It seems like right now it's not possible to change them using confluent-kafka-python lib since it's not supported in [ResourceType](https://github.com/confluentinc/confluent-kafka-python/blob/master/src/confluent_kafka/admin/_resource.py#L19) How...
Description =========== The documentation for the Python library refers to librdkafka's [CONFIGURATION.md](https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md) file when it comes to available config options. However, this is very far from ideal, as it is...
Description =========== In my project, I am using `confluent-kafka-python-1.9.2` to consumer and produce messages onto kafka topic. OAuth provider is already set by the other team and token gets expires...
