JimmyWang6 opened a new pull request, #14327: URL: https://github.com/apache/kafka/pull/14327
This pull request implements the server-side functionality for regex subscriptions in the next generation of the consumer rebalance protocol. For the ConsumerGroupHeartbeat API, the server now accepts a regex pattern, and a constraint is enforced that only one of either the regular subscription pattern or topic name subscription is allowed. The subscribedTopicRegex is eventually transformed into subscribedTopicName in the ConsumerGroupMember. To handle this, an additional argument, TopicsImage, is introduced in the maybeUpdateSubscribedTopicNames() function. This argument is used to filter the topics that match the regex pattern. During replay, when the function is called with a null TopicsImage argument, the regex expression is not considered. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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
