summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-03-22 16:53:53 -0700
committerDana Powers <dana.powers@gmail.com>2016-03-22 16:53:53 -0700
commit53b6bf2731db137e86a0894b296602dcccc88407 (patch)
tree55c1bc1f484d5a586a55dfcee228364f66bb13e0
parent33c7a9a374db06ed3882b2fe997ab6dc3a1abeab (diff)
downloadkafka-python-53b6bf2731db137e86a0894b296602dcccc88407.tar.gz
Remove errant next(consumer) from consumer documentation
-rw-r--r--README.rst1
-rw-r--r--docs/index.rst1
2 files changed, 0 insertions, 2 deletions
diff --git a/README.rst b/README.rst
index 8b40519..8e12632 100644
--- a/README.rst
+++ b/README.rst
@@ -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)