confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Hi, When i run java consumer code, i get lot of informative/kafka internal logs out of the box in addition to application logs ( via logging package or println )...
- [Mirrors PR 56](https://github.com/marcosschroh/python-schema-registry-client/pull/56/files) in `python-schema-registry-client` - Attempted to use `AvroSerialzer` and `AvroDeserializer` within pyspark udfs to (un)serialize contents of a dataframe but ran into ```TypeError: cannot pickle '_thread.lock' object```...
The `key.deserializer` and `value.deserializer` were documented as taking the context first, but are called with the context last.
This patch adds an option to supply an oauth callback to the SchemaRegistryClient so that it accepts oauth tokens in the same way that kafka brokers can receive tokens. The...
Description =========== In case an error happened on Kerberos request authentification `librdkafka` will provide some logs which also are not returned into python space and for just `None` returned from...
Description =========== I want to consume messages from eventhub using oauth authentification. I configured a service principal and get the access token via Azure Identity. However, I get following error...
Description =========== If you run a unit test over and over the number of stopped containers in Docker just piles up. How to reproduce ================ Run the unit tests for...
Description =========== At the beginning consumer connects and reads records from topic as should. At one moment (after several hours) connection with broker restarts, partitions unassign and all the other...
Description =========== The `cimpl` is a binary and IDE can't import definition from it. How to reproduce ================ I see that in my VS Code IDE it's an error telling...
Windows is conspicuously missing from list of OSes with build/install notes