Allow group coordinator to close when all brokers are unavailable (#660)

Fixes #659
aio-libs · Nov 13, 2020 · fff2c02 · fff2c02
1 parent f7f55b1
commit fff2c02
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/CHANGES.rst b/CHANGES.rst
@@ -2,6 +2,11 @@
 Changelog
 =========
 
+
+659.bugfix
+Allow group coordinator to close when all brokers are unavailable
+
+
 0.7.0 (2020-10-28)
 ==================
 

diff --git a/aiokafka/consumer/group_coordinator.py b/aiokafka/consumer/group_coordinator.py
@@ -519,7 +519,7 @@ async def ensure_coordinator_known(self):
 
         async with self._coordinator_lookup_lock:
             retry_backoff = self._retry_backoff_ms / 1000
-            while self.coordinator_id is None:
+            while self.coordinator_id is None and not self._closing.done():
                 try:
                     coordinator_id = (
                         await self._client.coordinator_lookup(