From ec8908d7ef1f59e0fb5bde5a351d62b4f17c4c8a Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 24 Feb 2025 13:11:29 -0800 Subject: [PATCH] Remove unused client bootstrap backoff code --- kafka/client_async.py | 18 ++---------------- 1 file changed, 2 insertions(+), 16 deletions(-) diff --git a/kafka/client_async.py b/kafka/client_async.py index 1bde074a3..67014488f 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -216,6 +216,8 @@ def __init__(self, **configs): self._connecting = set() self._sending = set() self._refresh_on_disconnects = True + + # Not currently used, but data is collected internally self._last_bootstrap = 0 self._bootstrap_fails = 0 @@ -233,8 +235,6 @@ def __init__(self, **configs): self.config['metric_group_prefix'], weakref.proxy(self._conns)) - self._num_bootstrap_hosts = len(collect_hosts(self.config['bootstrap_servers'])) - # Check Broker Version if not set explicitly if self.config['api_version'] is None: check_timeout = self.config['api_version_auto_timeout_ms'] / 1000 @@ -259,20 +259,6 @@ def _close_wakeup_socketpair(self): self._wake_r = None self._wake_w = None - def _can_bootstrap(self): - effective_failures = self._bootstrap_fails // self._num_bootstrap_hosts - backoff_factor = 2 ** effective_failures - backoff_ms = min(self.config['reconnect_backoff_ms'] * backoff_factor, - self.config['reconnect_backoff_max_ms']) - - backoff_ms *= random.uniform(0.8, 1.2) - - next_at = self._last_bootstrap + backoff_ms / 1000.0 - now = time.time() - if next_at > now: - return False - return True - def _can_connect(self, node_id): if node_id not in self._conns: if self.cluster.broker_metadata(node_id):