Skip to content

Commit 6579253

Browse files
committed
Retry group joins on CoordinatorLoadInProgress error
This is a temporary error, so can be safely retried.
1 parent 99244c1 commit 6579253

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

lib/kafka/consumer_group.rb

+6
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,12 @@ def join_group
161161
@member_id = ""
162162
sleep 1
163163

164+
retry
165+
rescue CoordinatorLoadInProgress
166+
@logger.error "Coordinator broker still loading, retrying in 1s..."
167+
168+
sleep 1
169+
164170
retry
165171
end
166172

0 commit comments

Comments
 (0)