Starting on unit tests

Updated several methods in KafkaClient to be classmethods. Updated some
inline documentation also

1 files changed, 2 insertions, 2 deletions

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)