KIP-345 Static membership implementation #137
Merged
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Hello!
I understand that the project is not actively maintained due to this issue nowadays but I hope this changes may help if new maintainer would be found.
I tried to implement stable static consumer group membership as it was declared in KIP-345, was released in 2.3.0 and mentioned in dpkp#2147.
This behaviour now would be reached by setting the next two values:
After that group rebalancing won't be triggered on consumer restarts or new deployments with the same
group_instance_id
, but developers should set the value ofsession_timeout_ms
(and other related) big enough.The second param
leave_group_on_close
is required because of this issue.So, now you can see in a broker's log something like that:
Also I didn't touch functionality that this KIP does not implement, as you can see in JoinGroupRequest / SyncGroupRequest / LeaveGroupRequest.
I would be glad to hear what should I do else to make this PR merged.
This change is