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 !

Reply via email to