Fix `value_deserializer` parameter in example

1 files changed, 1 insertions, 1 deletions

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)