From d9f886b88de92b266e32b6c9c4706728d6169645 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 25 Jan 2016 16:40:59 -0800 Subject: Fix Fetch._create_fetch_requests docstring --- kafka/consumer/fetcher.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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() -- cgit v1.2.1