confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== The library calls Python APIs (`Logger.log` specifically) without checking whether the Python error indicator was set. https://github.com/confluentinc/confluent-kafka-python/blob/5a87879681d28375a55203c4839338b13b668046/src/confluent_kafka/src/confluent_kafka.c#L1834 As [Python docs](https://docs.python.org/3/c-api/exceptions.html), > If the error is not handled or...
Specifying a Python list for config `bootstrap.servers` fails silently with no errors or indications
Description =========== The configuration key `bootstrap.servers` implies that multiple servers can be specified, but it is not explicitly defined what this key's value should be. It appears that only a...
Adjust the docstring so it is clear the function is the built in `__len__` function and not some newly defined `len` function on this object.
Description =========== Facing issue while trying communication to Kafka over SSL via Admin Client. Configuration: `{'bootstrap.servers': 'X.X.X.X:X', 'security.protocol': 'ssl', 'ssl.ca.location': 'ca-cert-path'}` confluent-python version: 1.9.2 works perfect but same breaks when...
The following example shows how to configure the producer with OAUTH. For Confluent Cloud where we need to pass extensions for "logicalCluster" and "identityPoolId" we need to pass some additional...
Description =========== I've installed the module confluent_kafka==1.8.2 for a function azure and I've got and error: ``` Result: Failure Exception: AttributeError: module 'os' has no attribute 'add_dll_directory' Stack: File "/azure-functions-host/workers/python/3.8/LINUX/X64/azure_functions_worker/dispatcher.py",...
Description =========== Documentation of [Kafka Client Configuration](https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#kafka-client-configuration) mentions keyword-only argument `logger` in constructors of Consumer and Producer.  This argument is not listed in documentation of [Consumer](https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#consumer) and [Producer](https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#producer). In...
