[KAFKA-9146] Add option to force delete members in stream reset tool

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.6.0
• Component/s: consumer, streams
• Labels: newbie
• Assignee: Haoran Xuan
• Reporter: Boyang Chen
• Created: 05/Nov/19 22:37
• Updated: 30/May/20 04:30
• Resolved: 28/May/20 01:41

Description

Sometimes people want to reset the stream application sooner, but blocked by the left-over members inside group coordinator, which only expire after session timeout. When user configures a really long session timeout, it could prevent the group from clearing. We should consider adding the support to cleanup members by forcing them to leave the group. To do that, 

1. If the stream application is already on static membership, we could call directly from adminClient.removeMembersFromGroup
2. If the application is on dynamic membership, we should modify adminClient.removeMembersFromGroup interface to allow deletion based on member.id.

Issue Links

• links to: GitHub Pull Request #8589
• mentioned in: Page Loading...