我试图复制博客中给出的步骤。在尝试时,出现了一个 Kafka Consumer
以及 Kafka Producer
python代码,我能够在python交互终端中运行代码,并且能够由使用者控制台提供输出,但是如果我在python文件中传递它们 (*.py)
,它不消耗任何东西。
消费者
from kafka import KafkaConsumer
consumer = KafkaConsumer('sample')
for message in consumer:
print (message)
制作人
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='localhost:9092')
producer.send('sample', b'Hello, World!')
producer.send('sample', key=b'message-two', value=b'This is Kafka-Python')
如何使它在python文件中工作?
1条答案
按热度按时间t9aqgxwy1#
我刚刚在producer代码中添加了producer.flush(),它就开始工作了。
因为Kafka的客户端是成批发送消息的,不能立即减少对代理的负载。
您最初发送的数据不足,无法自行刷新,因此在应用程序结束时,您的数据只是存储在内存中。
参考
batch.size
生产者财产