From c8662bfa6baa9fdd6bb0fd1b8b893f7f35a461f7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Cristi=20Burc=C4=83?= 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(-) 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 `_ 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 From 637f47c80f5cf203fb94d06b05ccc622d74c1891 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Cristi=20Burc=C4=83?= Date: Wed, 2 Mar 2016 05:56:01 +0200 Subject: Fix `value_deserializer` parameter in example --- docs/index.rst | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/index.rst b/docs/index.rst index ea138b0..d8f826a 100644 --- a/docs/index.rst +++ b/docs/index.rst @@ -58,7 +58,7 @@ that expose basic message attributes: topic, partition, offset, key, and value: >>> msg = next(consumer) >>> # Deserialize msgpack-encoded values ->>> consumer = KafkaConsumer(value_deserializer=msgpack.dumps) +>>> consumer = KafkaConsumer(value_deserializer=msgpack.loads) >>> consumer.subscribe(['msgpackfoo']) >>> for msg in consumer: ... msg = next(consumer) -- cgit v1.2.1