diff options
author | Dana Powers <dana.powers@gmail.com> | 2016-03-22 16:53:53 -0700 |
---|---|---|
committer | Dana Powers <dana.powers@gmail.com> | 2016-03-22 16:53:53 -0700 |
commit | 53b6bf2731db137e86a0894b296602dcccc88407 (patch) | |
tree | 55c1bc1f484d5a586a55dfcee228364f66bb13e0 | |
parent | 33c7a9a374db06ed3882b2fe997ab6dc3a1abeab (diff) | |
download | kafka-python-53b6bf2731db137e86a0894b296602dcccc88407.tar.gz |
Remove errant next(consumer) from consumer documentation
-rw-r--r-- | README.rst | 1 | ||||
-rw-r--r-- | docs/index.rst | 1 |
2 files changed, 0 insertions, 2 deletions
@@ -62,7 +62,6 @@ that expose basic message attributes: topic, partition, offset, key, and value: >>> consumer = KafkaConsumer(value_deserializer=msgpack.dumps) >>> consumer.subscribe(['msgpackfoo']) >>> for msg in consumer: -... msg = next(consumer) ... assert isinstance(msg.value, dict) diff --git a/docs/index.rst b/docs/index.rst index eb8f429..b98f119 100644 --- a/docs/index.rst +++ b/docs/index.rst @@ -61,7 +61,6 @@ that expose basic message attributes: topic, partition, offset, key, and value: >>> consumer = KafkaConsumer(value_deserializer=msgpack.loads) >>> consumer.subscribe(['msgpackfoo']) >>> for msg in consumer: -... msg = next(consumer) ... assert isinstance(msg.value, dict) |