diff options
author | David Arthur <mumrah@gmail.com> | 2013-04-01 14:56:59 -0400 |
---|---|---|
committer | David Arthur <mumrah@gmail.com> | 2013-04-01 14:56:59 -0400 |
commit | 8bf624e7102ab263e009c93bb85b484270727ba0 (patch) | |
tree | d9c9224049c6847eacc28b351fbf3dfbb0b967d7 /example.py | |
parent | 4f945684961a021ed399d0c1b472444ea2e90581 (diff) | |
download | kafka-python-8bf624e7102ab263e009c93bb85b484270727ba0.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) |