创建自己的卡夫卡普洛杜

Question

我正在学习Kafka，我试图用python编写自己的producer。在

我正在尝试使用简单循环，但遇到断言错误：

from kafka import KafkaProducer
from kafka.errors import KafkaError

producer = KafkaProducer(bootstrap_servers=['127.0.0.1:7092'])
for x in range (10):
    topic = "kafkatopic"
    producer.send(topic=topic,value="text")
    x=x+1

不知道为什么。在

Answer 1

您可以测试此代码，我使用Kafka Python client包：

producer.py：

from kafka import KafkaProducer

producer = KafkaProducer(
    bootstrap_servers=['XX.XXX.XXX.XXX:9092'],
)
for x in range (10):
    producer.send('kafkatopic', b'this is a test')
    producer.flush()

print('finish')

consumer.py

^{pr2}$