confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== To install confluent_kafka with kerberos support, we need to compile rdkafka from source and then install confluent_kafka without downloading the wheel, via: pip install --no-binary :all: confluent-kafka However,...
# Description Hello! I got a strange output when I was doing some tests through Pytest: ``` INTERNALERROR> Traceback (most recent call last): INTERNALERROR> File "/my_project_path/venv/lib/python3.10/site-packages/_pytest/main.py", line 270, in wrap_session...
Description =========== Code runs before connection has been established. How to reproduce ================ ``` .... producer = Producer(config); print('CONNECTED') .... ``` Checklist ========= Please provide the following information: - [X]...
Description =========== - confluent-kafka-python 1.7.0 - librdkafka 1.7.0 - apache kafka broker 2.4.2 I'm running hundreds consumers of a consumer group at once. Sometimes by unknown errors many of consumers...
Description =========== I use `AdminClient` in confluent-kafka-python and I would like to find a way to get "the size of topics partitions on disk by broker" in python ? I...
Description =========== i want to have some costume strategy when producing a message in a topic with 72 partitions i was able to achieve my goal in kafka-python-client as mentioned...
We have an experimental patch which adds support for setting `connect_cb` as a configuration, however looking back we found [this issue from 2017 ](https://github.com/confluentinc/confluent-kafka-python/issues/219#issuecomment-315983155) which says that adding it would...
Admin client raises _TIMED_OUT error rather than SASL authentication error when topic creation fails
Description =========== When `security.protocol: SASL_SSL` is configured on the admin client and invalid credentials are provided, topic creation fails as expected. However, the error that is raised is a `KafkaError._TIMED_OUT`...
Description =========== Hi, Could anyone please help me or shed some light on the below? I'm getting the content of certificate file (ca.crt file ) from the environment variable key....
Description =========== For some reason the `send_offsets_to_transaction()` call will be 50+ times slower when there is more than one message in the input topic of the transactor. How to reproduce...
