We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e15fe17 commit 4710d7dCopy full SHA for 4710d7d
lib/kafka/consumer_group.rb
@@ -56,6 +56,9 @@ def join
56
def leave
57
@logger.info "Leaving group `#{@group_id}`"
58
59
+ # Having a generation id indicates that we're a member of the group.
60
+ @generation_id = nil
61
+
62
@instrumenter.instrument("leave_group.consumer", group_id: @group_id) do
63
coordinator.leave_group(group_id: @group_id, member_id: @member_id)
64
end
0 commit comments