From c8662bfa6baa9fdd6bb0fd1b8b893f7f35a461f7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Cristi=20Burc=C4=83?= <scribu@gmail.com>
Date: Tue, 1 Mar 2016 20:10:54 +0200
Subject: Fix `value_serializer` parameter in example

`json.loads()` is for deserialising.
---
 docs/index.rst | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'docs')

diff --git a/docs/index.rst b/docs/index.rst
index 6ce228a..ea138b0 100644
--- a/docs/index.rst
+++ b/docs/index.rst
@@ -84,7 +84,7 @@ client. See `KafkaProducer <apidoc/KafkaProducer.html>`_ for more details.
 
 >>> # Serialize json messages
 >>> import json
->>> producer = KafkaProducer(value_serializer=json.loads)
+>>> producer = KafkaProducer(value_serializer=lambda v: json.dumps(v).encode('utf-8'))
 >>> producer.send('fizzbuzz', {'foo': 'bar'})
 
 >>> # Serialize string keys
-- 
cgit v1.2.1