使用python操作常用的库-kafka
安装kafka-python
pip3 install kafka-python
生产者
producer_test.py
'''
遇到问题没人解答？小编创建了一个Python学习交流QQ群：857662006
寻找有志同道合的小伙伴，互帮互助,群里还有不错的视频学习教程和PDF电子书！
'''
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='192.168.0.121:9092') # 连接kafka
msg = "Hello World".encode('utf-8') # 发送内容,必须是bytes类型
producer.send('test', msg) # 发送的topic为test
producer.close()
执行此程序，它没有输出！这个是正常的
消费者
from kafka import KafkaConsumer
consumer = 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)
执行此程序，此时会hold住，因为它在等待生产者发送消息！
再次执行生产者，此时会输出：
test:0:9: key=None value=b'Hello World'
