diff options
| author | anentropic <ego@anentropic.com> | 2012-11-22 13:18:34 +0000 |
|---|---|---|
| committer | anentropic <ego@anentropic.com> | 2012-11-22 13:18:34 +0000 |
| commit | 60aef76a9ab684a5b680e0c15d034744fc71620f (patch) | |
| tree | 846dcc6c62d57e4b2fff013fe9dfea68cbfdc033 | |
| parent | 1d0bc784d41364d6178dce452f2ac787b52749a8 (diff) | |
| download | kafka-python-60aef76a9ab684a5b680e0c15d034744fc71620f.tar.gz | |
fix docs: iter_messages doesn't (any longer?) take a FetchRequest
...it takes the same args and instantiates its own one
| -rw-r--r-- | README.md | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -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() ``` |
