python讀取Kafka例項
阿新 • • 發佈:2020-01-09
1. 新建.py檔案
# pip install kafka-python from kafka import KafkaConsumer import setting conf = setting.luyang_kafka_setting consumer = KafkaConsumer(bootstrap_servers=conf['host'],group_id=conf['groupid']) print('consumer start to consuming...') consumer.subscribe((conf['topic'],)) for message in consumer: print(message.topic,message.offset,message.key,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例項就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支援我們。