diff options
author | David Arthur <mumrah@gmail.com> | 2013-04-01 14:56:59 -0400 |
---|---|---|
committer | David Arthur <mumrah@gmail.com> | 2013-04-02 20:19:30 -0400 |
commit | 0678a452ca7ad5fba8e947cbfcf8fcb0f87b902c (patch) | |
tree | d4011fc89717f1eb9884787ae333be5b525bacd4 /example.py | |
parent | b6d98c07b418b16061ae92392947d5dd6958a708 (diff) | |
download | kafka-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.py | 26 |
1 files changed, 10 insertions, 16 deletions
@@ -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) |