summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDavid Arthur <mumrah@gmail.com>2012-11-22 06:55:32 -0800
committerDavid Arthur <mumrah@gmail.com>2012-11-22 06:55:32 -0800
commit81ff0f5991dca7bf604b7f6f281681a5b4421649 (patch)
tree846dcc6c62d57e4b2fff013fe9dfea68cbfdc033
parent1d0bc784d41364d6178dce452f2ac787b52749a8 (diff)
parent60aef76a9ab684a5b680e0c15d034744fc71620f (diff)
downloadkafka-python-81ff0f5991dca7bf604b7f6f281681a5b4421649.tar.gz
Merge pull request #11 from anentropic/master
fix docs: iter_messages doesn't (any longer?) take a FetchRequest
-rw-r--r--README.md4
1 files changed, 2 insertions, 2 deletions
diff --git a/README.md b/README.md
index 01d8e0c..5169eb8 100644
--- a/README.md
+++ b/README.md
@@ -147,7 +147,7 @@ to provide a generator that returns every message available.
```python
kafka = KafkaClient("localhost", 9092)
-for msg in kafka.iter_messages(FetchRequest("my-topic", 0, 0, 1024*1024)):
+for msg in kafka.iter_messages("my-topic", 0, 0, 1024*1024):
print(msg.payload)
kafka.close()
```
@@ -156,7 +156,7 @@ An optional `auto` argument will control auto-paging through results
```python
kafka = KafkaClient("localhost", 9092)
-for msg in kafka.iter_messages(FetchRequest("my-topic", 0, 0, 1024*1024), False):
+for msg in kafka.iter_messages("my-topic", 0, 0, 1024*1024, False):
print(msg.payload)
kafka.close()
```