# Collection of code snippets by Arne Vajhøj 
# (from articles on eksperten.dk / vajhoej.dk written sometime between 2004 and now) 
from kafka import KafkaProducer

SERVER = 'localhost:9092'
TNAME = 'TestT'
PAYLOAD = '<data>\r\n    <id>123</id>\r\n    <name>ABC</name>\r\n</data>'
sender = KafkaProducer(bootstrap_servers=SERVER)
for i in range(3):
    sender.send(TNAME, key=str(i), value=PAYLOAD) # both key and value send as strings
sender.flush()