confluent-kafka-python icon indicating copy to clipboard operation
confluent-kafka-python copied to clipboard

Confluent's Kafka Python Client

Results 381 confluent-kafka-python issues
Sort by recently updated
recently updated
newest added

- Introduced pyproject.toml - Moved static metadata from setup.py - Removed Python 3.6 support - Updated RELEASE.md

Description =========== Currently the setuptools integration is installing the LICENSE.txt as a datafile. datafiles are meant to be used for installation of files needed at runtime of the library. the...

Description =========== The `SerializationContext` class documentation implies that an instance of `MessageField` can be passed for the `field` parameter. However, `MessageField` is not an actual Enum, leading to a discrepancy...

Description =========== (Changing a discussion to an issue, since it is fairly straightforward) From python, calling a Consumer's commit function with parameters set to None (or other python False values)...

Closes #1535 and #1585 Added a bunch of nice to have feature if you're writting unit tests involving a lot of message handling: * Made Messages instantiatable from Python *...

Fixing styles with automatic style fix make command. As this is the new project, we should use latest version of clang-format. Currently, using v15. We should keep clang-format version up-to...

Description =========== Using the confluent avro python client it will not deserialize messages that have a schema with a dash in the namespace field. How to reproduce ================ Create a...

schema registry

Description =========== Currently, the docs to not mention that a method configured as callback for oauth_cb can return two optional values in addition to the required once. Instead of "(token_str,...

docs
priority:high

Description =========== The `enable.ssl.certificate.verification` configuration for `AdminClient` only takes strings `"true"`/`"false"` rather than the Python booleans `True`/`False`. We noticed that even though we would set `enable.ssl.certificate.verification: False` in our configuration,...

investigate further