Fix value_deserializer parameter in example

2016-03-02 05:56:01 +02:00
parent c8662bfa6b
commit 637f47c80f
1 changed files with 1 additions and 1 deletions
--- 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)