From 6579253c6609efec9f4d89a5961771d0bfb1395b Mon Sep 17 00:00:00 2001
From: Daniel Schierbeck <daniel@dasch.io>
Date: Sat, 30 May 2020 15:04:28 +0200
Subject: [PATCH] Retry group joins on CoordinatorLoadInProgress error

This is a temporary error, so can be safely retried.
---
 lib/kafka/consumer_group.rb | 6 ++++++
 1 file changed, 6 insertions(+)

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