diff options
author | Dana Powers <dana.powers@rd.io> | 2016-01-25 16:40:59 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@rd.io> | 2016-01-25 16:40:59 -0800 |
commit | d9f886b88de92b266e32b6c9c4706728d6169645 (patch) | |
tree | 6a74b274d5273160115b3b3a0234d8956185ccc1 | |
parent | 654f6b62470e88bf6e76fcf12ab1f9136eba7e1f (diff) | |
download | kafka-python-d9f886b88de92b266e32b6c9c4706728d6169645.tar.gz |
Fix Fetch._create_fetch_requests docstring
-rw-r--r-- | kafka/consumer/fetcher.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 11e5063..0e822c4 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -512,7 +512,7 @@ class Fetcher(six.Iterator): FetchRequests skipped if no leader, or node has requests in flight Returns: - dict: {node_id: [FetchRequest,...]} + dict: {node_id: FetchRequest, ...} """ # create the fetch info as a dict of lists of partition info tuples # which can be passed to FetchRequest() via .items() |