Skip to content

Apache kafka 14147#21723

Closed
shiva2405 wants to merge 2 commits intoapache:trunkfrom
shiva2405:apache-kafka-14147
Closed

Apache kafka 14147#21723
shiva2405 wants to merge 2 commits intoapache:trunkfrom
shiva2405:apache-kafka-14147

Conversation

@shiva2405
Copy link
Copy Markdown

Description

We need to provide the functionality for an explicit LeaveGroup request to handle removing members from a group within the new generic group coordinator infrastructure.

Acceptance Criteria:

  1. Handle the LeaveGroup request: Build the core logic to remove members from a group when they issue an explicit LeaveGroup request.
  2. Scheduling: The CoordinatorRuntime write operation should be named "generic-group-leave".
  3. Core API Methods: Add the public method public CoordinatorResult<LeaveGroupResponseData, Record> genericGroupLeave(RequestContext context, LeaveGroupRequestData request) to GroupMetadataManager.
  4. Shard Layer Wrapper: Add the corresponding wrapper method public CoordinatorResult<LeaveGroupResponseData, Record> genericGroupLeave(RequestContext context, LeaveGroupRequestData request) in GroupCoordinatorShard.java.
  5. Static members: When processing members, if the memberId is undefined (UNKNOWN_MEMBER_ID), fallback to checking if a groupInstanceId is provided to remove static members. If neither is valid, return an UNKNOWN_MEMBER_ID error.
  6. Validation: In the top-level GroupCoordinatorService#leaveGroup implementation, immediately reject empty or invalid group IDs with an INVALID_GROUP_ID error.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant