kafka生产者示例（kafka-python producer example）

import multiprocessing import time from kafka import KafkaProducer def worker(ch): producer = KafkaProducer(bootstrap_servers='127.0.0.1:9092') for i in range(1000): time.sleep(0.01

>>阅读原文<<