【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

>>阅读原文<<