confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
When using the [SchemaRegistryClient](https://github.com/confluentinc/confluent-kafka-python/blob/master/src/confluent_kafka/schema_registry/schema_registry_client.py) class, we find that its methods for working with schemas and subjects are not consistently covering the Schema Registry REST API. Below are listed all the...
Description =========== Currently, if json data has extra fields in the record, `AvroSerializer` will not fail, it will silently ignore the extra fields, which can be detrimental in some applications,...
Description =========== It's not necessarily a bug, the Producer class has a False-y truth value when there's no enqueued items. This is caused by the combination of the default `nb_bool`...
These changes are related to the users getting confused for logger callback property. In the docs we refer to librdkafka properties first then explain logger properties of python client. Due...
Description =========== Currently, if you run `mypy` with a project with this in, you get `error: Skipping analyzing "confluent_kafka.admin": module is installed, but missing library stubs or py.typed marker [import]`...
Description =========== I start a kafka producer in subprocess,and it stop and could not continue run How to reproduce ================ ``` import sys from confluent_kafka import Producer from config import...
Hi, I was wondering if you would like to integrate continuous fuzzing by way of OSS-Fuzz? Fuzzing is a way to automate test-case generation and can be used to find...
Description =========== The number of open file handles is not proportional with the number of Consumer(s) in a process. I have a simple example where I create N `Consumer`(s) in...
