Skip to content

Commit f7c8510

Browse files
authored
Merge pull request #833 from zendesk/dasch-hardening
Add some hardening
2 parents 99244c1 + 6579253 commit f7c8510

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)