confluent-kafka-python
confluent-kafka-python copied to clipboard
Confluent's Kafka Python Client
Description =========== Hi there, I have identified minor yet impactful typing inconsistencies within the `schema_registry` module in the package. While these inconsistencies might appear subtle, they can have consequences for...
Fixes https://github.com/confluentinc/confluent-kafka-python/issues/1590 which is about the Producer class Also realized that the same error affected the AdminClient class, so also fixed that. And then cleaned up the Consumer code to...
Adds simple support for an (optional) `proxy` param when configuring the `SchemaRegistryClient`. If specified - it will use the supplied proxy details when making requests. If not specified, requests will...
Fixes #1564 JSONSerializer changes: - Added schema.validator parameter to conf, allowing use of different JSON validators - Default behavior [schema.validator == None] unchanged - Added _validator attribute - Added explicit...
The Trogdor Runner executes Trogdor ExternalCommandSpec tasks. It can be invoked directly from command line `./tests/trogdor_runner --spec ExternalCommandSpecFile`, or driven by Trogdor agents. When running from command, the Trogdor Runner...
try number 2 to strike a balance between informative/useful/concise
1. Add 'include_dirs', and 'library_dirs' to compile setting of module. 2. Remove python 2.7 from cibuildwheel's build list 3. Add batch file to download librdkafka from nuget then call tools/wheels/build-wheels.bat...
Description =========== Getting this error `SSL handshake failed: error:0A000086:SSL routines::certificate verify failed: broker certificate could not be verified, verify that ssl.ca.location is correctly configured or root CA certificates are installed...