Avoid busy poll during metadata refresh failure with retry_backoff_msmetadata_refresh_backoff

1 files changed, 4 insertions, 0 deletions

diff --git a/kafka/cluster.py b/kafka/cluster.py
index 3309d1f..9aabec1 100644
--- a/kafka/cluster.py
+++ b/kafka/cluster.py
@@ -131,6 +131,10 @@ class ClusterMetadata(object):
 
         return max(ttl, next_retry, 0)
 
+    def refresh_backoff(self):
+        """Return milliseconds to wait before attempting to retry after failure"""
+        return self.config['retry_backoff_ms']
+
     def request_update(self):
         """Flags metadata for update, return Future()