Page History

...

1) Changes in org.apache.kafka.clients.admin.MemberToRemove 

Previously the org.apache.kafka.clients.admin.the KafkaAdminClient#removeMembersFromConsumerGroup only supports to remove members by specifying the groupInstanceId, which means it only supports the removal of static members, so the memberId is added to support removing dynamic members. Since there are two String fields now, new helpers are added and the old constructor will be deprecated.

...

While with the new option, the StreamsResetter will force remove all active members fetched by first calling KafkaAdminClient#describeConsumerGroups, and all the then calling KafkaAdminClient#removeMembersFromConsumerGroup with active members list fetched from the first call. All the deleted members' info will be logged out if all removals succeed. Otherwise,  the first member removal error will be thrown. 

...