summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2016-01-25 16:40:59 -0800
committerDana Powers <dana.powers@rd.io>2016-01-25 16:40:59 -0800
commitd9f886b88de92b266e32b6c9c4706728d6169645 (patch)
tree6a74b274d5273160115b3b3a0234d8956185ccc1
parent654f6b62470e88bf6e76fcf12ab1f9136eba7e1f (diff)
downloadkafka-python-d9f886b88de92b266e32b6c9c4706728d6169645.tar.gz
Fix Fetch._create_fetch_requests docstring
-rw-r--r--kafka/consumer/fetcher.py2
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()