confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== This package does not build on PyPy because it uses `PyException_HEAD` which does not exist in the PyPy headers. How to reproduce ================ See https://github.com/conda-forge/python-confluent-kafka-feedstock/pull/85 Checklist ========= Please...
Description =========== As opposed to most other methods in the `AdminClient`, the `list_topics` method does not return a future. However, the c implementation does release the gil before the metadata...
Description =========== Pre-build binary wheels are not working on Alpine and pip is trying to compile library from sources on this system. Installing from sources is working but we need...
Added script to install confluent_kafka module and do a sanity test with multiple python versions.
Access denied error for IAM role based AWS MSK cluster while using confluent-kafka python library
Description =========== Here is the overview of the application, it consumes from the upstream kafka cluster processes the kafka message and produces it to the downstream kafka cluster using the...
Description =========== confluent_kafka.Producer class has Owner. This is making any class that takes a dependency on Producer not testable. How to reproduce ================ Create a class that takes dependency on...
Description =========== I am trying to create a consumer subscribed to more than one topic. Some of the topics may not exist which appears to create an issue with the...
Description =========== I am writing a Flask API to retrieve data from Apache Kafka topics. The consumer subscribes to a different topic each time according to the API path and...
Allow to pass a RegisteredSchema to Avro Serializer and Deserializer. This will avoid to read a Schema from SchemaRegister if this it was sourced.
