Fix `value_serializer` parameter in example

`json.loads()` is for deserialising.

1 files changed, 1 insertions, 1 deletions

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