diff options
| -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() |