[kafka] branch trunk updated (4a6287e832 -> 8245c9a3d5)

[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 4a6287e832 MINOR: fix ClientQuotasRequestTest (#12107)
     add 8245c9a3d5 KAFKA-13854 Refactor ApiVersion to MetadataVersion (#12072)

No new revisions were added by this update.

Summary of changes:
 build.gradle                                       |   1 +
 checkstyle/suppressions.xml                        |   4 +
 .../kafka/common/requests/ApiVersionsResponse.java |  28 ++
 .../common/requests/ApiVersionsResponseTest.java   | 108 +++++
 .../kafka/server/builders/LogManagerBuilder.java   |   6 +-
 core/src/main/scala/kafka/api/ApiVersion.scala     | 500 ---------------------
 core/src/main/scala/kafka/cluster/Partition.scala  |   5 +-
 .../controller/ControllerChannelManager.scala      |  35 +-
 .../scala/kafka/controller/KafkaController.scala   |  30 +-
 .../kafka/controller/PartitionStateMachine.scala   |   5 +-
 .../coordinator/group/GroupMetadataManager.scala   |  23 +-
 .../TransactionMarkerChannelManager.scala          |   5 +-
 core/src/main/scala/kafka/log/LogConfig.scala      |  22 +-
 core/src/main/scala/kafka/log/LogManager.scala     |   9 +-
 core/src/main/scala/kafka/log/LogValidator.scala   |  10 +-
 core/src/main/scala/kafka/log/UnifiedLog.scala     |  15 +-
 .../kafka/security/authorizer/AclAuthorizer.scala  |   6 +-
 .../scala/kafka/server/AbstractFetcherThread.scala |   6 +-
 .../scala/kafka/server/AlterPartitionManager.scala |   7 +-
 .../scala/kafka/server/ApiVersionManager.scala     |  19 +-
 .../main/scala/kafka/server/ConfigHandler.scala    |   2 +-
 .../main/scala/kafka/server/ControllerServer.scala |   4 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  27 +-
 core/src/main/scala/kafka/server/KafkaConfig.scala |  44 +-
 core/src/main/scala/kafka/server/KafkaServer.scala |   8 +-
 .../scala/kafka/server/ReplicaFetcherThread.scala  |  52 +--
 .../main/scala/kafka/server/ReplicaManager.scala   |   6 +-
 core/src/main/scala/kafka/zk/ZkData.scala          |  20 +-
 .../kafka/admin/ConfigCommandIntegrationTest.scala |   4 +-
 .../admin/ReassignPartitionsIntegrationTest.scala  |   7 +-
 .../FetchRequestBetweenDifferentIbpTest.scala      |  30 +-
 .../kafka/server/FetchRequestTestDowngrade.scala   |   9 +-
 .../MetadataRequestBetweenDifferentIbpTest.scala   |  13 +-
 .../unit/kafka/admin/FeatureCommandTest.scala      |   5 +-
 .../test/scala/unit/kafka/api/ApiVersionTest.scala | 287 ------------
 .../unit/kafka/cluster/AbstractPartitionTest.scala |   6 +-
 .../unit/kafka/cluster/PartitionLockTest.scala     |   7 +-
 .../scala/unit/kafka/cluster/PartitionTest.scala   |  19 +-
 .../PartitionWithLegacyMessageFormatTest.scala     |  10 +-
 .../controller/ControllerChannelManagerTest.scala  | 122 ++---
 .../controller/ControllerIntegrationTest.scala     |  38 +-
 .../controller/PartitionStateMachineTest.scala     |   5 +-
 .../group/GroupMetadataManagerTest.scala           |  69 +--
 .../LogCleanerParameterizedIntegrationTest.scala   |  12 +-
 .../test/scala/unit/kafka/log/LogConfigTest.scala  |   7 +-
 .../test/scala/unit/kafka/log/LogLoaderTest.scala  |  10 +-
 .../scala/unit/kafka/log/LogValidatorTest.scala    |  82 ++--
 .../kafka/security/auth/ZkAuthorizationTest.scala  |   5 +-
 .../security/authorizer/AclAuthorizerTest.scala    |  14 +-
 .../kafka/server/AlterPartitionManagerTest.scala   |  61 +--
 .../unit/kafka/server/ApiVersionManagerTest.scala  |  12 +-
 .../kafka/server/DynamicConfigChangeTest.scala     |   6 +-
 .../FetchRequestWithLegacyMessageFormatTest.scala  |   6 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  30 +-
 .../scala/unit/kafka/server/KafkaConfigTest.scala  |  25 +-
 .../scala/unit/kafka/server/KafkaServerTest.scala  |   6 +-
 .../kafka/server/ReplicaFetcherThreadTest.scala    |  14 +-
 .../unit/kafka/server/ReplicaManagerTest.scala     |   3 +-
 .../TopicIdWithOldInterBrokerProtocolTest.scala    |   4 +-
 .../unit/kafka/server/UpdateFeaturesTest.scala     |   6 +-
 ...chDrivenReplicationProtocolAcceptanceTest.scala |  10 +-
 ...eplicationProtocolAcceptanceWithIbp26Test.scala |   4 +-
 .../test/scala/unit/kafka/utils/TestUtils.scala    |   7 +-
 .../scala/unit/kafka/zk/KafkaZkClientTest.scala    |   7 +-
 .../jmh/fetcher/ReplicaFetcherThreadBenchmark.java |   7 +-
 .../partition/PartitionMakeFollowerBenchmark.java  |   7 +-
 .../UpdateFollowerFetchStateBenchmark.java         |   7 +-
 .../CompressedRecordBatchValidationBenchmark.java  |   4 +-
 .../apache/kafka/jmh/server/CheckpointBench.java   |   4 +-
 .../kafka/jmh/server/PartitionCreationBench.java   |   4 +-
 .../kafka/server/common/MetadataVersion.java       | 288 ++++++++++++
 .../server/common/MetadataVersionValidator.java    |  20 +-
 .../kafka/server/common/MetadataVersionTest.java   | 343 ++++++++++++++
 .../common/MetadataVersionValidatorTest.java       |  18 +-
 74 files changed, 1354 insertions(+), 1317 deletions(-)
 delete mode 100644 core/src/main/scala/kafka/api/ApiVersion.scala
 delete mode 100644 core/src/test/scala/unit/kafka/api/ApiVersionTest.scala
 create mode 100644 server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java
 copy connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/RegexValidator.java => server-common/src/main/java/org/apache/kafka/server/common/MetadataVersionValidator.java (64%)
 create mode 100644 server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionTest.java
 copy connect/api/src/test/java/org/apache/kafka/connect/storage/ConverterTypeTest.java => server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionValidatorTest.java (73%)