Kafka Producer(Python threading)

import threading import time import random from kafka import KafkaProducer producer = KafkaProducer(bootstrap_servers='192.168.1.10:9092') threads = [] class MyThread(threading.Thread): def __init

>>阅读原文<<