andrewchoi5 opened a new pull request #8479: URL: https://github.com/apache/kafka/pull/8479
KAFKA-9769: Finish operations for leaderEpoch-updated partitions up to point ZK Exception occurs. https://issues.apache.org/jira/browse/KAFKA-9769 For example, in such case, we will have the following mechanism : 1 - P1 and P2 succeeds. leaderEpoch for them are incremented because no ZkException occurs 2 - while making follower for P3, ZkException occurs and the leaderEpoch is not updated and thus thepartitionsToMakeFollower += partition isn’t executed. We catch this ZkException in line 1498 and log it as an error. No Exception is thrown. 3 - After catching the exception, makeFollower for P4 is then not executed. 4 - so the partitionsToMakeFollower only contains P1, P2. And fetchers are added to these partitionsToMakeFollower Signed-off-by: Andrew Choi <li_andc...@microsoft.com> ### 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
