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 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) |