[kafka] branch trunk updated (4669011 -> a30f92b)

[cm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 4669011  KAFKA-10885 Refactor MemoryRecordsBuilderTest/MemoryRecordsTest to avoid a lot of… (#9906)
     add a30f92b  MINOR: Add KIP-500 BrokerServer and ControllerServer (#10113)

No new revisions were added by this update.

Summary of changes:
 checkstyle/import-control.xml                      |   1 +
 .../java/org/apache/kafka/clients/ApiVersions.java |  13 +-
 .../org/apache/kafka/clients/ApiVersionsTest.java  |  17 +
 .../kafka/clients/admin/KafkaAdminClientTest.java  |   4 +-
 core/src/main/scala/kafka/cluster/Broker.scala     |   2 +-
 core/src/main/scala/kafka/log/LogConfig.scala      |   2 +-
 .../main/scala/kafka/network/SocketServer.scala    |  37 +-
 .../scala/kafka/raft/KafkaNetworkChannel.scala     |   3 +-
 core/src/main/scala/kafka/raft/RaftManager.scala   |   2 +
 .../main/scala/kafka/server/AlterIsrManager.scala  |   5 +-
 .../kafka/server/AutoTopicCreationManager.scala    |  15 +-
 .../src/main/scala/kafka/server/BrokerServer.scala | 468 ++++++++++++++++++++-
 .../server/BrokerToControllerChannelManager.scala  |  36 ++
 .../main/scala/kafka/server/ControllerApis.scala   | 453 ++++++++++++++++++++
 .../main/scala/kafka/server/ControllerServer.scala | 198 ++++++++-
 .../main/scala/kafka/server/EnvelopeUtils.scala    | 137 ++++++
 core/src/main/scala/kafka/server/KafkaApis.scala   | 103 +----
 core/src/main/scala/kafka/server/KafkaBroker.scala |   8 +
 core/src/main/scala/kafka/server/KafkaConfig.scala |  32 +-
 .../main/scala/kafka/server/KafkaRaftServer.scala  |  33 +-
 core/src/main/scala/kafka/server/KafkaServer.scala |  11 +-
 .../main/scala/kafka/server/MetadataSupport.scala  |  20 +-
 core/src/main/scala/kafka/server/Server.scala      |  12 +
 .../main/scala/kafka/tools/TestRaftServer.scala    |   2 +-
 .../server/AutoTopicCreationManagerTest.scala      |  12 +-
 .../unit/kafka/server/ControllerApisTest.scala     | 143 +++++++
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  40 +-
 .../scala/unit/kafka/server/KafkaConfigTest.scala  | 114 ++++-
 .../unit/kafka/server/KafkaRaftServerTest.scala    |   2 +-
 .../jmh/metadata/MetadataRequestBenchmark.java     |   5 +-
 .../org/apache/kafka/raft/KafkaRaftClient.java     |  21 +-
 .../java/org/apache/kafka/raft/NetworkChannel.java |   5 +
 .../java/org/apache/kafka/raft/RaftClient.java     |  11 +-
 .../java/org/apache/kafka/raft/RaftConfig.java     |  13 +
 .../org/apache/kafka/raft/ReplicatedCounter.java   |   2 +-
 .../kafka/raft/metadata/MetaLogRaftShim.java       | 119 ++++++
 .../org/apache/kafka/raft/MockNetworkChannel.java  |   5 +
 .../apache/kafka/raft/RaftClientTestContext.java   |   2 +-
 tests/kafkatest/services/kafka/config_property.py  |   2 +-
 39 files changed, 1908 insertions(+), 202 deletions(-)
 create mode 100644 core/src/main/scala/kafka/server/ControllerApis.scala
 create mode 100644 core/src/main/scala/kafka/server/EnvelopeUtils.scala
 create mode 100644 core/src/test/scala/unit/kafka/server/ControllerApisTest.scala
 create mode 100644 raft/src/main/java/org/apache/kafka/raft/metadata/MetaLogRaftShim.java