confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== When oauth token expire, the reauth op is receive by both consumer and producer even when no producer client has ever being created, resulting in continuous error log....
Description =========== `jsonschema` version is not constrained by this package and we are seeing warning in our test runs. `jsonschema 4.23.0 An implementation of JSON Schema valid` ``` ============================== warnings...
* [KIP-848] Added support for testing with new 'consumer' group protocol. * Build fixes * updated trivup * Updated trivup install path * Fixed failing test * Style fix *...
Description =========== I am deploying a Python solution on Azure Kubernetes. The code subscribes to a Topic in Azure EventHub. Everything worked well - till the time I switched to...
Description =========== When trying to authenticate in kafka using the [SchemaRegistryClient ](https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#schemaregistryclient )class I get the error (Caused by SSLError(SSLCertVerificationError(1, '[SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed: unable to get local issuer...
Description =========== I call flush in my setup and expect the message to be sent, and no warning produced, but a simple test of having one message produced, then a...
A handful of minor fixes to cimpl. Probably nothing that will impact real-life use-cases, since these are all buried inside `_AdminClientImpl`, but they were bothering me. 1. Swaps `"topic_names"` and...
`PyEval_InitThreads()` is redundant as of Python 3.7, is a no-op (and is deprecated) as of Python 3.9, and will be removed in Python 3.11 - only call it when using...
