Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
from kafka import *
mykafka = KafkaClient("localhost:9092")
producer = SimpleProducer(mykafka)
producer.send_messages("test", "mymessage")
producer.send_messages("test", "mymessage 2")
producer.send_messages("test", "mymessage 3")
producer.send_messages("test", "mymessage 4")
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.