confluent-kafka-python Questions
2
Solved
I'm using confluent-kafka-client. I have one producer producing into a topic with one partition and one consumer within one group ID. First, I create a producer (with default configs) for the topic...
Cytosine asked 25/4 at 2:14
7
I am using the confluent-kafka Python client in my project. I'm trying to create a Docker image with this client.
I am facing the following error:-
#11 8.015 [pipenv.exceptions.InstallError]: In fi...
Downswing asked 8/5, 2022 at 18:12
2
Here's what I've tried so far:
from confluent_kafka import Consumer
c = Consumer({... several security/server settings skipped...
'auto.offset.reset': 'beginning',
'group.id': 'my-group'})
c.su...
Giant asked 8/2, 2021 at 21:37
2
Solved
I am trying to use the confluent-kafka python library to administer my cluster via a lambda function but the function fails with the error:
"Unable to import module 'Test': No module named 'co...
Administration asked 5/9, 2020 at 18:52
0
I'm new to Kafka, using confluent kafka and trying to write messages to existing kafka topic from AWS EC2 instance using python producer code with 'sasl.mechanism': 'PLAIN','security.protocol': 'SA...
Nestornestorian asked 23/3, 2021 at 12:29
1
I have VM run on ubuntu 18.04.
On that I installed:
python3.7
confluent-kafka
when run python script, I met this message error:
from .cimpl import (Consumer, #noqa
ModuleNotFoundError: no mod...
Kery asked 17/9, 2020 at 9:42
1
© 2022 - 2024 — McMap. All rights reserved.