JimmyWang6 commented on PR #14327:
URL: https://github.com/apache/kafka/pull/14327#issuecomment-1757298813

   @dajac 
   Much Thanks for your review!
   As for target assignment updates, the function 
`maybeUpdateSubscribedTopicNames(oldMember, newMember)`
   
![image](https://github.com/apache/kafka/assets/48462172/a6b17c61-6686-4069-b729-a332d5439150)
   The old member's **RegexSubscribedTopics** has been converted to 
**subscribedTopicNames()**, 
   and subscriptions can be reduced by using 
subscribedTopicCount.compute(topicName, ConsumerGroup::decValue). 
   The new member's RegexSubscribedTopics will be transformed into 
subscribedTopicNames through **getRegexSubscribedTopics()**.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to