Merge pull request #833 from zendesk/dasch-hardening

Add some hardening
zendesk · Jun 2, 2020 · f7c8510 · f7c8510
2 parents 99244c1 + 6579253
commit f7c8510
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