confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
* Added support for testing with new 'consumer' group protocol. * Fixed a incorrect testcase.
Description =========== Confluent-kafka-python will exit with an error when running in the twisted framework. I found that using version 1.9.2 can run in the twisted framework, but versions after 2.0.2...
Description =========== I was doing some testing with the Admin client where I delete and recreate topics over and over again with new names over a period of three days...
Importing TopicCollection as ``` from confluent_kafka import TopicCollection ``` raises: ``` error: Module "confluent_kafka" has no attribute "TopicCollection" ``` The type is not listed in `__all__` at https://github.com/confluentinc/confluent-kafka-python/blob/5a87879681d28375a55203c4839338b13b668046/src/confluent_kafka/__init__.py#L25
Description =========== Log messages are not logged via logger. How to reproduce ================ ```python import logging import sys from confluent_kafka.admin import AdminClient logging.basicConfig(stream=sys.stdout, level=logging.DEBUG) logger=logging.getLogger("AdminClient") logger.info("Running...") client = AdminClient({ "bootstrap.servers":...
Description =========== **NOTE: This is a question and not an issue** I am building an application with FastAPI, this application will also need to consume messages from kafka. Thus we...
Description =========== https://github.com/confluentinc/confluent-kafka-python/blob/5a87879681d28375a55203c4839338b13b668046/src/confluent_kafka/schema_registry/json_schema.py#L272-L279 When validating certain special types, modifications to the 'validate' method are required, as shown below: ```python from jsonschema import validate, ValidationError, RefResolver, Draft202012Validator validate(instance=value, schema=self._parsed_schema, format_checker=Draft202012Validator.FORMAT_CHECKER) ```...
I am using 32bit python3.12 on Windows for some reason, I tried to install with pip but failed, and I checked the whl list, there is no resource for 32bit...
