【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_serial

>>阅读原文<<