From 29ae9aef92e03c640a3d14a5591d98fcab8851e3 Mon Sep 17 00:00:00 2001 From: David Arthur Date: Mon, 24 Sep 2012 09:01:29 -0400 Subject: Setting up a stand-alone repository for this --- example.py | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 example.py (limited to 'example.py') diff --git a/example.py b/example.py new file mode 100644 index 0000000..c58751b --- /dev/null +++ b/example.py @@ -0,0 +1,29 @@ +import logging + +from kafka import KafkaClient, FetchRequest, ProduceRequest +from kafka import create_message_from_string + +def produce_example(kafka): + message = create_message_from_string("test") + request = ProduceRequest("my-topic", 0, [message]) + print("Sending %s" % str(request)) + kafka.send_message_set(request) + +def consume_example(kafka): + request = FetchRequest("my-topic", 0, 0, 64) + print("Sending %s" % str(request)) + (messages, nextRequest) = kafka.get_message_set(request) + print("Got %d messages:" % len(messages)) + for message in messages: + print("\t%s" % message.payload) + print("Next request %s" % str(nextRequest)) + +def main(): + kafka = KafkaClient("localhost", 9092) + produce_example(kafka) + consume_example(kafka) + + +if __name__ == "__main__": + logging.basicConfig(level=logging.DEBUG) + main() -- cgit v1.2.1