dongnuo123 opened a new pull request, #15662: URL: https://github.com/apache/kafka/pull/15662
Based on https://github.com/apache/kafka/pull/15411, the pr contains triggering of group conversion from a classic group to a consumer group. In consumerGroupHeartbeat, the online migration will be triggered if a joining request (the request member epoch is 0) to an non-empty classic group is received. The converting method will create a new consumer group according to the existing classic group. The new consumer group's reference will be used in the following member joining process but will not be persisted to the timeline data structure until the records are replayed. A special case to consider is when the replay of the conversion and joining records fail. A possible solution is discussed in https://github.com/apache/kafka/pull/15587. ### 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
