diff options
| -rw-r--r-- | docs/index.rst | 2 |
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 |