summaryrefslogtreecommitdiff
path: root/example.py
diff options
context:
space:
mode:
authorDavid Arthur <mumrah@gmail.com>2013-04-01 14:56:59 -0400
committerDavid Arthur <mumrah@gmail.com>2013-04-02 20:19:30 -0400
commit0678a452ca7ad5fba8e947cbfcf8fcb0f87b902c (patch)
treed4011fc89717f1eb9884787ae333be5b525bacd4 /example.py
parentb6d98c07b418b16061ae92392947d5dd6958a708 (diff)
downloadkafka-python-0678a452ca7ad5fba8e947cbfcf8fcb0f87b902c.tar.gz
Refactoring a bit, cleanup for 0.8
Marking some stuff as not compatible for 0.8 (will be added in 0.8.1)
Diffstat (limited to 'example.py')
-rw-r--r--example.py26
1 files changed, 10 insertions, 16 deletions
diff --git a/example.py b/example.py
index 9329312..1e4bd8b 100644
--- a/example.py
+++ b/example.py
@@ -2,27 +2,21 @@ import logging
from kafka.client import KafkaClient, FetchRequest, ProduceRequest
from kafka.consumer import SimpleConsumer
+from kafka.producer import SimpleProducer
-def produce_example(kafka):
- message = kafka.create_message("testing")
- request = ProduceRequest("my-topic", -1, [message])
- kafka.send_message_set(request)
+def produce_example(client):
+ producer = SimpleProducer(client, "my-topic")
+ producer.send_message("test")
-def consume_example(kafka):
- request = FetchRequest("my-topic", 0, 0, 1024)
- (messages, nextRequest) = kafka.get_message_set(request)
- for message in messages:
- print("Got Message: %s" % (message,))
- print(nextRequest)
-
-def produce_gz_example(kafka):
- message = kafka.create_gzip_message("this message was gzipped", "along with this one")
- request = ProduceRequest("my-topic", 0, [message])
- kafka.send_message_set(request)
+def consume_example(client):
+ consumer = SimpleConsumer(client, "test-group", "my-topic")
+ for message in consumer:
+ print(message)
def main():
client = KafkaClient("localhost", 9092)
- consumer = SimpleConsumer(client, "test-group", "my-topic")
+ produce_example(client)
+ consume_example(client)
if __name__ == "__main__":
logging.basicConfig(level=logging.DEBUG)