cmccabe opened a new pull request #10564: URL: https://github.com/apache/kafka/pull/10564
Centralize leader and ISR changes in generateLeaderAndIsrUpdates. Consolidate handleNodeDeactivated and handleNodeActivated into this function. Rename BrokersToIsrs#noLeaderIterator to BrokersToIsrs#partitionsWithNoLeader. Create BrokersToIsrs#partitionsLedByBroker, BrokersToIsrs#partitionsWithBrokerInIsr In ReplicationControlManagerTest, createTestTopic should be a member function of ReplicationControlTestContext. It should invoke ReplicationControlTestContext#replay so that records are applied to all parts of the test context. -- 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