confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== It would be nice if the SchemaRegistryClient() support a "url" string which is a comma-separated list of schema registry URLs instead of just a single schema registry URL....
Description =========== When using the `group.instance.id` for two consumers and they conflict, the fenced client receives an ambiguous error. The `.code()` of the error is `KafkaError._FATAL` which is generic, but...
Description =========== The `Message` object returned by `DeserializingConsumer.value()` doesn't appear to match the [signature](https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#confluent_kafka.Message.value)- it can return a `dict`, for example, and not only a `str` or `bytes`. How to...
Description =========== Hello, I have a code with a producer. I want to know if there is a method to know if there is any error or no connection in...
Description =========== We had 100 partitions and 100 consumers and things worked as expected. But last night I increased number of partitions to 1000 and number of consumers to 200....
Description =========== Greetings. We're trying to upgrade to package v2.5.0 from v2.4.0 but found a hard time. - Confluent community v6.1 brokers and consumer with package 2.4.0 works - Confluent...
Description =========== I have tried to install `confluent-kafka` using the command `pip install confluent-kafka` with python version `3.13.0rc1`. The installation fails with the following error: ```txt In file included from...
Description =========== Feature request. When pausing a consumer, it would be nice if there was a way to check if the consumer is paused. For example a consumer could be...
Description =========== We have been observing that our consumer client hangs once in a while randomly inside the commit call. This has started happening only after upgrading to 2.2.0 release....
