From 752c6e649eef95b96dd0ddca356c9c77ff32de5a Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 13 Mar 2019 21:46:36 -0700 Subject: Do not user bootstrap_topics_filter unless topics is empty --- kafka/client_async.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) (limited to 'kafka/client_async.py') diff --git a/kafka/client_async.py b/kafka/client_async.py index 9ce0f32..a5be3cd 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -784,10 +784,9 @@ class KafkaClient(object): return self.config['reconnect_backoff_ms'] if self._can_send_request(node_id): - if node_id == 'bootstrap': + topics = list(self._topics) + if not topics and node_id == 'bootstrap': topics = list(self.config['bootstrap_topics_filter']) - else: - topics = list(self._topics) if self.cluster.need_all_topic_metadata or not topics: topics = [] if self.config['api_version'] < (0, 10) else None -- cgit v1.2.1