diff options
author | David Arthur <mumrah@gmail.com> | 2012-11-22 06:55:32 -0800 |
---|---|---|
committer | David Arthur <mumrah@gmail.com> | 2012-11-22 06:55:32 -0800 |
commit | 81ff0f5991dca7bf604b7f6f281681a5b4421649 (patch) | |
tree | 846dcc6c62d57e4b2fff013fe9dfea68cbfdc033 | |
parent | 1d0bc784d41364d6178dce452f2ac787b52749a8 (diff) | |
parent | 60aef76a9ab684a5b680e0c15d034744fc71620f (diff) | |
download | kafka-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.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() ``` |