From 1a0f2973190e2bb60909bfcd28e5ad8e732e918e Mon Sep 17 00:00:00 2001 From: Brian Sang Date: Thu, 23 May 2019 09:07:11 -0700 Subject: Fix typo in _fetch_all_topic_metadata function (#1809) --- kafka/consumer/group.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 39a4e08..6c12767 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -552,7 +552,7 @@ class KafkaConsumer(six.Iterator): committed = None return committed - def _fetch_all_topit_metadata(self): + def _fetch_all_topic_metadata(self): """A blocking call that fetches topic metadata for all topics in the cluster that the user is authorized to view. """ -- cgit v1.2.1