Questions about kafka-python
Read more about kafka-python
python (65.1k questions)
javascript (44.2k questions)
reactjs (22.7k questions)
java (20.8k questions)
c# (17.4k questions)
html (16.3k questions)
r (13.7k questions)
android (12.9k questions)
Why do I get Intermittent "NoBrokersAvailable" errors, with python application (kafka-python Producer)?
I’m trying to make a connection to Kafka on AWS. Communication is done over TLS.<br>
Kafka-python==2.0.2 is used, and the KafkaProducer configuration is as follows:
From Kafka import KafkaProduc...
bowoojang
Votes: 0
Answers: 2
Error "certificate has expired" when connecting to Confluent Cloud Kafka
I created a Kafka cluster at https://confluent.cloud/. I am trying to write a simple producer, with kafka-python.
Here is my producer code:
from kafka import KafkaProducer
producer = KafkaProducer(
...
Wallace Kelly
Votes: 0
Answers: 1
Set consumer offset
If I want get all messages from to start offset, I run this shell command:
/usr/share/kafka/bin/kafka-console-consumer.sh
--bootstrap-server localhost:9092
--topic 1-codicefiscale-21032022122736-i
...
user18480960
Votes: 0
Answers: 1
Kafka python consumer not receiving new data inserted into the source data
I have my source database as Mysql and sink database as Cassandra. Python producer code establishes connection with Mysql and sends data to kafka topic, in my case the topic name is demo. The consumer...
Tej Patel
Votes: 0
Answers: 0