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 8b5d755bf67 KAFKA-17685 Define common testRuntimeOnly dependencies
(#17355)
add 85bfdf4127e KAFKA-17613: Remove ZK migration code (#17293)
No new revisions were added by this update.
Summary of changes:
.../MigrationControllerChannelContext.scala | 115 ---
.../kafka/migration/MigrationPropagator.scala | 251 -----
.../kafka/migration/MigrationPropagatorBatch.scala | 85 --
.../scala/kafka/server/ApiVersionManager.scala | 11 +-
.../server/ControllerRegistrationManager.scala | 3 +-
.../main/scala/kafka/server/ControllerServer.scala | 59 +-
.../main/scala/kafka/tools/TestRaftServer.scala | 1 -
.../main/scala/kafka/zk/ZkMigrationClient.scala | 356 -------
.../kafka/zk/migration/ZkAclMigrationClient.scala | 118 ---
.../zk/migration/ZkConfigMigrationClient.scala | 394 -------
.../ZkDelegationTokenMigrationClient.scala | 97 --
.../zk/migration/ZkTopicMigrationClient.scala | 358 -------
.../unit/kafka/network/SocketServerTest.scala | 2 +-
.../server/BrokerRegistrationRequestTest.scala | 93 +-
.../unit/kafka/server/ControllerApisTest.scala | 1 -
.../server/ControllerRegistrationManagerTest.scala | 1 -
.../scala/unit/kafka/server/KafkaApisTest.scala | 1 -
.../metadata/KRaftMetadataRequestBenchmark.java | 1 -
.../jmh/metadata/MetadataRequestBenchmark.java | 1 -
.../controller/ActivationRecordsGenerator.java | 107 +-
.../kafka/controller/ClusterControlManager.java | 34 +-
.../kafka/controller/FeatureControlManager.java | 10 -
.../kafka/controller/OffsetControlManager.java | 2 +-
.../kafka/controller/PartitionChangeBuilder.java | 23 +-
.../apache/kafka/controller/QuorumController.java | 166 +--
.../controller/ReplicationControlManager.java | 6 -
.../metrics/QuorumControllerMetrics.java | 50 +-
.../metadata/migration/AclMigrationClient.java | 40 -
.../metadata/migration/BufferingBatchConsumer.java | 58 --
.../metadata/migration/ConfigMigrationClient.java | 63 --
.../migration/DelegationTokenMigrationClient.java | 38 -
.../metadata/migration/KRaftMigrationDriver.java | 1088 --------------------
.../migration/KRaftMigrationOperation.java | 23 -
.../migration/KRaftMigrationOperationConsumer.java | 23 -
.../metadata/migration/KRaftMigrationZkWriter.java | 684 ------------
.../kafka/metadata/migration/LegacyPropagator.java | 37 -
.../kafka/metadata/migration/MigrationClient.java | 91 --
.../migration/MigrationClientAuthException.java | 26 -
.../migration/MigrationClientException.java | 38 -
.../metadata/migration/MigrationDriverState.java | 61 --
.../metadata/migration/MigrationManifest.java | 129 ---
.../metadata/migration/TopicMigrationClient.java | 85 --
.../kafka/metadata/migration/ZkRecordConsumer.java | 30 -
.../controller/ActivationRecordsGeneratorTest.java | 200 +---
.../controller/ClusterControlManagerTest.java | 29 -
.../controller/PartitionChangeBuilderTest.java | 53 +-
.../QuorumControllerMetricsIntegrationTest.java | 2 +-
.../kafka/controller/QuorumControllerTest.java | 311 +-----
.../metrics/QuorumControllerMetricsTest.java | 73 +-
.../migration/CapturingAclMigrationClient.java | 56 -
.../migration/CapturingConfigMigrationClient.java | 76 --
.../CapturingDelegationTokenMigrationClient.java | 54 -
.../migration/CapturingMigrationClient.java | 204 ----
.../migration/CapturingTopicMigrationClient.java | 114 --
54 files changed, 107 insertions(+), 5925 deletions(-)
delete mode 100644
core/src/main/scala/kafka/migration/MigrationControllerChannelContext.scala
delete mode 100644
core/src/main/scala/kafka/migration/MigrationPropagator.scala
delete mode 100644
core/src/main/scala/kafka/migration/MigrationPropagatorBatch.scala
delete mode 100644 core/src/main/scala/kafka/zk/ZkMigrationClient.scala
delete mode 100644
core/src/main/scala/kafka/zk/migration/ZkAclMigrationClient.scala
delete mode 100644
core/src/main/scala/kafka/zk/migration/ZkConfigMigrationClient.scala
delete mode 100644
core/src/main/scala/kafka/zk/migration/ZkDelegationTokenMigrationClient.scala
delete mode 100644
core/src/main/scala/kafka/zk/migration/ZkTopicMigrationClient.scala
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/AclMigrationClient.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/BufferingBatchConsumer.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/ConfigMigrationClient.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/DelegationTokenMigrationClient.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationOperation.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationOperationConsumer.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationZkWriter.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/LegacyPropagator.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationClient.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationClientAuthException.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationClientException.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationDriverState.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationManifest.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/TopicMigrationClient.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/ZkRecordConsumer.java
delete mode 100644
metadata/src/test/java/org/apache/kafka/metadata/migration/CapturingAclMigrationClient.java
delete mode 100644
metadata/src/test/java/org/apache/kafka/metadata/migration/CapturingConfigMigrationClient.java
delete mode 100644
metadata/src/test/java/org/apache/kafka/metadata/migration/CapturingDelegationTokenMigrationClient.java
delete mode 100644
metadata/src/test/java/org/apache/kafka/metadata/migration/CapturingMigrationClient.java
delete mode 100644
metadata/src/test/java/org/apache/kafka/metadata/migration/CapturingTopicMigrationClient.java
