This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from af2e8bc KAFKA-12245; Fix flaky
`FetcherTest.testEarlierOffsetResetArrivesLate` (#10006)
add 62218a0 MINOR: Factor out controller node provider
`BrokerToControllerChannelManager` (#10015)
No new revisions were added by this update.
Summary of changes:
.../main/scala/kafka/server/AlterIsrManager.scala | 4 +-
.../server/BrokerToControllerChannelManager.scala | 61 +++++++++++++----
.../scala/kafka/server/ForwardingManager.scala | 4 +-
.../BrokerToControllerRequestThreadTest.scala | 79 +++++++---------------
4 files changed, 78 insertions(+), 70 deletions(-)
