From 7486d8704f21acb454c23764162d22a59cdfa3e8 Mon Sep 17 00:00:00 2001 From: David Arthur Date: Thu, 27 Sep 2012 10:36:37 -0400 Subject: Starting on unit tests Updated several methods in KafkaClient to be classmethods. Updated some inline documentation also --- example.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'example.py') diff --git a/example.py b/example.py index 0204af1..6ec223c 100644 --- a/example.py +++ b/example.py @@ -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) -- cgit v1.2.1