Write data to Kafka using Python

The first step is to install pykafka

pip install pykafka

PyKafka — pykafka 2.8.1-dev.2 documentation

The second step is to write the data code of the corresponding subject , Here are just demo

from pykafka import KafkaClient
client = KafkaClient(hosts="192.168.220.202:9092,192.168.220.203:9092,192.168.220.204:9092")
topic = client.topics['tea']
with topic.get_sync_producer() as producer:
for i in range(10000):
producer.produce(('test message ' + str(i)).encode())