Skip to content

[KIP-848] Fix static group membership #4994

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
wants to merge 1 commit into
base: master
Choose a base branch
from

Conversation

emasab
Copy link
Contributor

@emasab emasab commented Mar 14, 2025

there are three cases for static group membership this PR fixes the first one:

  • member explicitly unsubscribes -> should cause a rebalance
  • member closes the consumer -> no rebalance
  • member destroys the consumer -> no rebalance

When a new member joins the group and there's already a member with same group instance id that hasn't left statically the new member is fenced with the new protocol

Warning

The test won't work until regex implementation is merged

@confluent-cla-assistant
Copy link

🎉 All Contributor License Agreements have been signed. Ready to merge.
Please push an empty commit if you would like to re-run the checks to verify CLA status for all contributors.

the contract is changed to be the same as
the Java client, the member only releases partitions
on session.timeout.ms reached.
KIP-1092 to be implemented in a separate PR
to leave permanently the group with static membership
before session.timeout.ms is reached.

When a new member joins the group and there's
already a member with same group instance id
that hasn't left statically the incoming member
is fenced
@airlock-confluentinc airlock-confluentinc bot force-pushed the dev_kip848_fix_static_group_membership_leave branch from eda7068 to dfbf7e7 Compare March 17, 2025 10:57
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant