安裝kafka-python

pip3 install kafka-python

生產(chǎn)者
producer_test.py

''' 遇到問題沒人解答？小編創(chuàng)建了一個Python學習交流QQ群：857662006 尋找有志同道合的小伙伴，互幫互助,群里還有不錯的視頻學習教程和PDF電子書！ ''' from kafka import KafkaProducerproducer = KafkaProducer(bootstrap_servers='192.168.0.121:9092') # 連接kafkamsg = "Hello World".encode('utf-8') # 發(fā)送內(nèi)容,必須是bytes類型 producer.send('test', msg) # 發(fā)送的topic為test producer.close()

執(zhí)行此程序，它沒有輸出！這個是正常的

消費者

from kafka import KafkaConsumerconsumer = KafkaConsumer('test', bootstrap_servers=['192.168.0.121:9092']) for msg in consumer:recv = "%s:%d:%d: key=%s value=%s" % (msg.topic, msg.partition, msg.offset, msg.key, msg.value)print(recv)

執(zhí)行此程序，此時會hold住，因為它在等待生產(chǎn)者發(fā)送消息！

再次執(zhí)行生產(chǎn)者，此時會輸出：

test:0:9: key=None value=b'Hello World'

總結(jié)

以上是生活随笔為你收集整理的使用python操作常用的库-kafka的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。