From 89f83024945237adb1628388159f10a7484d16af Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 7 Apr 2016 08:02:37 -0700 Subject: [PATCH] Merge updates from PR 573 into README (serializer/deserializer examples) --- README.rst | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/README.rst b/README.rst index 8e12632..266f2a2 100644 --- a/README.rst +++ b/README.rst @@ -59,7 +59,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: ... assert isinstance(msg.value, dict) @@ -89,7 +89,7 @@ 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