confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== I'm getting the below error whenever I try to pip install confluent-kafka within my Dockerfile and I build that Dockerfile using python:3.10-slim-bullseye as my base image. ```error: #error...
Description =========== `docker run -ti python:3.8-slim-buster /bin/bash` `pip install confluent-kafka==1.8.2` The above commands produce different results on x86_64 and aarch64 platforms. Operating systems in use: - Fedora 34 (Intel i7)...
Description =========== I'm using `Python 3.10.2` and I have this message when I try to install into my `venv` environment running `pip install confluent-kafka` ``` In file included from /private/var/folders/td/w1gcl5210h74qmvykhkskw2w0000gn/T/pip-install-o7ox0olt/confluent-kafka_a282f0a8ff244cb0bfc2ae5297a17742/src/confluent_kafka/src/Admin.c:17:...
Description =========== I cannot install confluent-kafka on Apple's M1 host with neither Python 3.8 nor Python 3.9 with the provided instructions. Workaround ========== This is a combination of what @evgmoskalenko...
This PR addresses the issue to build arm64 wheels. Successful [Build](https://travis-ci.com/github/tbbharaj/confluent-kafka-python/builds/232243754) If there are any questions/comments - I'd be happy fix things as needed. Issue: https://github.com/confluentinc/confluent-kafka-python/issues/1182 Thank you Tanveen
Description =========== A bit of a context question: what is the most optimal consumption pattern if I have more than one topics, and possibly multiple partitions per topic to be...
Description =========== Section for [isolation.level](https://docs.confluent.io/platform/current/installation/configuration/consumer-configs.html#consumerconfigs_isolation.level) states that default value isolation.level should be read_uncommitted. But in [kafka-client-configuration](https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#kafka-client-configuration) section of confluent-kafka-python it is stated refer to [librdkafka’s documentation](https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md) that specifies default value...
Description =========== ``` from confluent_kafka import Consumer conf = { 'bootstrap.servers': 'localhost:8082', 'group.id': 'myconsumer', 'security.protocol': 'sasl_ssl', 'sasl.mechanism': 'PLAIN', 'sasl.username': 'myusername', 'sasl.password': 'badpassword' } consumer = Consumer(conf) ``` Invoking the code...
