【kafka连载四】window系统python环境发送消息和消费消息
前提
1.已安装kafka-python模块
2.已启动zookeeper服务
3.已启动kafka服务
一、编辑发送消息code
#coding=utf-8 from kafka import KafkaProducer import json producer = KafkaProducer(bootstrap_servers='127.0.0.1:9092',value_serializer=lambda v: json.dumps(v).encode('utf-8')) msg={"name":"sendvalue","age":30,"job":"tester"} #json_value=json.dumps(msg) producer.send('testtopic',msg) producer.flush() producer.close()
二、编辑消费消息code
#coding=utf-8 from kafka import KafkaConsumer consumer = KafkaConsumer( bootstrap_servers = "127.0.0.1:9092", group_id="testtopic_group" ) consumer.subscribe("testtopic") for each in consumer: print(each)
三、CMD窗口执行发送消息脚本
python 发送消息.py
四、Pycharm运行消费消息脚本
运行消费消息的脚本
五、控制台打印已消费的消息