Hi, all In order to make it possible for StreamsResetter to reset stream even when there are active members, since we currently only have the ability to remove static members, so we basically need the ability to remove dynamic members, this involves some public interfaces change in org.apache.kafka.clients.admin.MemberToRemove.
KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-571%3A+Add+option+to+force+remove+members+in+StreamsResetter JIRA: https://issues.apache.org/jira/browse/KAFKA-9146 Any comments would be highly appreciated~ Thanks !