shiva2405 opened a new pull request, #21723: URL: https://github.com/apache/kafka/pull/21723
### 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. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
