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 51833bf KAFKA-10648: Add Prefix Scan support to State Stores (#9508)
add 3acc193 MINOR: Add mock implementation of
`BrokerToControllerChannelManager` (#10026)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/clients/MockClient.java | 22 +++
.../main/scala/kafka/server/AlterIsrManager.scala | 2 +-
.../server/BrokerToControllerChannelManager.scala | 38 ++++-
.../scala/kafka/server/ForwardingManager.scala | 6 +-
.../unit/kafka/server/ForwardingManagerTest.scala | 172 +++++++++++----------
.../MockBrokerToControllerChannelManager.scala | 95 ++++++++++++
.../util/ReplicaFetcherMockBlockingSend.scala | 8 +-
7 files changed, 250 insertions(+), 93 deletions(-)
create mode 100644
core/src/test/scala/unit/kafka/server/MockBrokerToControllerChannelManager.scala
