From 53b6bf2731db137e86a0894b296602dcccc88407 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 22 Mar 2016 16:53:53 -0700 Subject: Remove errant next(consumer) from consumer documentation --- README.rst | 1 - docs/index.rst | 1 - 2 files changed, 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) -- cgit v1.2.1