python读取Kafka实例
1.新建.py文件
#pipinstallkafka-python
fromkafkaimportKafkaConsumer
importsetting
conf=setting.luyang_kafka_setting
consumer=KafkaConsumer(bootstrap_servers=conf['host'],group_id=conf['groupid'])
print('consumerstarttoconsuming...')
consumer.subscribe((conf['topic'],))
formessageinconsumer:
print(message.topic,message.offset,message.key,message.value,message.value,message.partition)
以上是kafka主要程序
2.Kafka配置文件setting.py
luyang_kafka_setting={
'host':'0.0.0.0:9092',
'topic':'zcfTest',
'groupid':'luyang1'
}
配置如上
3.执行结果
以上这篇python读取Kafka实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。