Producer using Kafka and ZooKeeper

test_kafka_producer.py

# Steven Van Dorpe, Aug 13, 2018
# 
# Reference: 
#     https://towardsdatascience.com/kafka-python-explained-in-10-lines-of-code-800e3e07dad1

from time import sleep
from json import dumps
from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers=['localhost:9092'],
                         value_serializer=lambda x: 
                         dumps(x).encode('utf-8'))

for e in range(1000):
    data = {'number' : e}
    producer.send('numtest', value=data)
    sleep(5)