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(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。