You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2021/02/01 22:32:28 UTC
[kafka] branch trunk updated (af2e8bc -> 62218a0)
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(-)