This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 36aab4fddd6 MINOR: Clarify consumer behaviour on partition pause &
re-assignments (#22538)
add be11cf8be72 KAFKA-20637: Move ForwardingManager to server module
(#22408)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
.../kafka/server/builders/KafkaApisBuilder.java | 2 +-
.../src/main/scala/kafka/server/BrokerServer.scala | 2 +-
.../scala/kafka/server/ForwardingManager.scala | 185 ------------
core/src/main/scala/kafka/server/KafkaApis.scala | 21 +-
.../unit/kafka/server/ForwardingManagerTest.scala | 308 --------------------
.../scala/unit/kafka/server/KafkaApisTest.scala | 12 +-
.../MockNodeToControllerChannelManager.scala | 105 -------
.../kafka/server/RegistrationTestContext.scala | 2 +-
.../metadata/KRaftMetadataRequestBenchmark.java | 2 +-
.../org/apache/kafka/server/ForwardingManager.java | 111 ++++++++
.../apache/kafka/server/ForwardingManagerImpl.java | 147 ++++++++++
.../apache/kafka/server/ForwardingManagerTest.java | 312 +++++++++++++++++++++
.../server/MockNodeToControllerChannelManager.java | 130 +++++++++
14 files changed, 722 insertions(+), 618 deletions(-)
delete mode 100644 core/src/main/scala/kafka/server/ForwardingManager.scala
delete mode 100644
core/src/test/scala/unit/kafka/server/ForwardingManagerTest.scala
delete mode 100644
core/src/test/scala/unit/kafka/server/MockNodeToControllerChannelManager.scala
create mode 100644
server/src/main/java/org/apache/kafka/server/ForwardingManager.java
create mode 100644
server/src/main/java/org/apache/kafka/server/ForwardingManagerImpl.java
create mode 100644
server/src/test/java/org/apache/kafka/server/ForwardingManagerTest.java
create mode 100644
server/src/testFixtures/java/org/apache/kafka/server/MockNodeToControllerChannelManager.java
