diff --git a/lib/kafka/consumer_group.rb b/lib/kafka/consumer_group.rb
index cf9fa775b..0178acf5c 100644
--- a/lib/kafka/consumer_group.rb
+++ b/lib/kafka/consumer_group.rb
@@ -161,6 +161,12 @@ def join_group
       @member_id = ""
       sleep 1
 
+      retry
+    rescue CoordinatorLoadInProgress
+      @logger.error "Coordinator broker still loading, retrying in 1s..."
+
+      sleep 1
+
       retry
     end