diff options
author | David Arthur <mumrah@gmail.com> | 2012-09-27 10:36:37 -0400 |
---|---|---|
committer | David Arthur <mumrah@gmail.com> | 2012-09-27 10:36:37 -0400 |
commit | 7486d8704f21acb454c23764162d22a59cdfa3e8 (patch) | |
tree | 786ac7afd4828f584011604eb4498ed1e40871d1 /example.py | |
parent | ab273c459fba1d47163b1ac5f1f7a3f0fe6f0215 (diff) | |
download | kafka-python-7486d8704f21acb454c23764162d22a59cdfa3e8.tar.gz |
Starting on unit tests
Updated several methods in KafkaClient to be classmethods. Updated some
inline documentation also
Diffstat (limited to 'example.py')
-rw-r--r-- | example.py | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -3,7 +3,7 @@ import logging from kafka import KafkaClient, FetchRequest, ProduceRequest def produce_example(kafka): - message = kafka.create_message_from_string("testing") + message = kafka.create_message("testing") request = ProduceRequest("my-topic", 0, [message]) kafka.send_message_set(request) @@ -15,7 +15,7 @@ def consume_example(kafka): print(nextRequest) def produce_gz_example(kafka): - message = kafka.create_gzipped_message("this message was gzipped", "along with this one") + message = kafka.create_gzip_message("this message was gzipped", "along with this one") request = ProduceRequest("my-topic", 0, [message]) kafka.send_message_set(request) |