【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运行消费消息脚本

运行消费消息的脚本

五、控制台打印已消费的消息