kafka-server-start /usr/local/etc/kafka/server.properties

kafka-console-producer --broker-list localhost:9092 --topic <topic name>

kafka-topics --list --zookeeper localhost:2181

>>> from pykafka import KafkaClient
>>> client = KafkaClient(hosts='127.0.0.1:9092')

>>> import json

with client.topics['sage_integration_service'].get_sync_producer() as producer:
    producer.produce(json.dumps({'name': 'bongani', 'surnamce': 'sibanda'}))