producer.py

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(10):
    data = {'number' : e}
    producer.send('numtest', value=data)
    print("produces %d"%e)
    sleep(1)