Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9146

Add option to force delete members in stream reset tool

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.6.0
    • Component/s: consumer, streams
    • Labels:

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                feyman feyman
                Reporter:
                bchen225242 Boyang Chen
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: