#================1================
#python链接kafka 获取里面的topic内容
#可能需要安装模块
#pip3 install kafka-python
from kafka.producer import KafkaProducer
from kafka import KafkaConsumer
#传入topic 及访问链接
consumer=KafkaConsumer('test123456',bootstrap_servers=['172.17.61.113:9092'])
print(consumer)
print('11111')
for msg in consumer:
print(msg.topic, msg.partition, msg.offset, msg.key, msg.value)
来自 “ ITPUB博客 ” ，链接：https://blog.itpub.net/30127122/viewspace-2679856/ ，如需转载，请注明出处，否则将追究法律责任。
上一篇：
redis基本操作
请登录后发表评论
登录
全部评论
