Retry group joins on CoordinatorLoadInProgress error

This is a temporary error, so can be safely retried.
zendesk · May 30, 2020 · 6579253 · 6579253
1 parent 99244c1
commit 6579253
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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