From b47c0e67ae5ef08ced45cc9fc37a536b7a45c394 Mon Sep 17 00:00:00 2001
From: sunisdown <isdown.sun@gmail.com>
Date: Thu, 11 Dec 2014 15:42:29 +0800
Subject: [PATCH] update low level

change KafkaProdocol.encode_message to create_message and change import ProduceRequest from kafka.common
---
 README.md | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/README.md b/README.md
index cbfb82c..6655b92 100644
--- a/README.md
+++ b/README.md
@@ -130,13 +130,14 @@ for message in consumer.get_messages(count=5, block=True, timeout=4):
 ## Low level
 
 ```python
-from kafka import KafkaClient
-from kafka.protocol import KafkaProtocol, ProduceRequest
+from kafka import KafkaClient, create_message
+from kafka.protocol import KafkaProtocol
+from kafka.common import ProduceRequest
 
 kafka = KafkaClient("localhost:9092")
 
 req = ProduceRequest(topic="my-topic", partition=1,
-    messages=[KafkaProtocol.encode_message("some message")])
+    messages=[create_message("some message")])
 resps = kafka.send_produce_request(payloads=[req], fail_on_error=True)
 kafka.close()