summaryrefslogtreecommitdiff
path: root/example.py
diff options
context:
space:
mode:
Diffstat (limited to 'example.py')
-rw-r--r--example.py29
1 files changed, 29 insertions, 0 deletions
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()