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 4c5ea05ec85 KAFKA-18058: Share group state record pruning impl.
(#18014)
add 772aa241b2f KAFKA-18136: Remove zk migration from code base (#18016)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/Kafka.scala | 9 +-
.../scala/kafka/controller/KafkaController.scala | 6 +-
core/src/main/scala/kafka/raft/RaftManager.scala | 2 -
core/src/main/scala/kafka/server/KafkaApis.scala | 6 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 43 +---
core/src/main/scala/kafka/server/KafkaServer.scala | 146 +-----------
.../main/scala/kafka/server/MetadataCache.scala | 5 +-
.../main/scala/kafka/server/ReplicaManager.scala | 24 +-
.../kafka/server/metadata/ZkMetadataCache.scala | 6 +-
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 250 +--------------------
core/src/main/scala/kafka/zk/ZkData.scala | 39 ----
.../kafka/server/QuorumTestHarness.scala | 2 +-
.../kafka/integration/KafkaServerTestHarness.scala | 8 +-
.../scala/unit/kafka/metrics/MetricsTest.scala | 8 +-
.../server/BrokerRegistrationRequestTest.scala | 33 +--
.../scala/unit/kafka/server/KafkaConfigTest.scala | 39 ----
.../unit/kafka/server/MetadataCacheTest.scala | 69 ------
.../unit/kafka/server/ReplicaManagerTest.scala | 75 +------
.../test/scala/unit/kafka/utils/TestUtils.scala | 7 +-
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 2 +-
.../controller/ActivationRecordsGenerator.java | 32 +--
.../kafka/controller/FeatureControlManager.java | 32 ---
.../apache/kafka/controller/QuorumController.java | 6 +-
.../apache/kafka/controller/QuorumFeatures.java | 22 --
.../ControllerMetadataMetricsPublisher.java | 4 -
.../java/org/apache/kafka/image/FeaturesDelta.java | 21 +-
.../java/org/apache/kafka/image/FeaturesImage.java | 31 +--
.../java/org/apache/kafka/image/MetadataDelta.java | 9 +-
.../apache/kafka/image/node/FeaturesImageNode.java | 2 -
.../migration/ZkMigrationLeadershipState.java | 202 -----------------
.../kafka/metadata/migration/ZkMigrationState.java | 108 ---------
.../common/metadata/ZkMigrationRecord.json | 4 +-
.../controller/ActivationRecordsGeneratorTest.java | 120 +---------
.../controller/FeatureControlManagerTest.java | 38 ----
.../kafka/controller/QuorumControllerTest.java | 38 +---
.../kafka/controller/QuorumFeaturesTest.java | 56 -----
.../org/apache/kafka/image/FeaturesImageTest.java | 14 +-
.../org/apache/kafka/image/ImageDowngradeTest.java | 2 -
.../kafka/image/publisher/SnapshotEmitterTest.java | 2 +-
.../apache/kafka/server/config/KRaftConfigs.java | 14 +-
40 files changed, 71 insertions(+), 1465 deletions(-)
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/ZkMigrationLeadershipState.java
delete mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/ZkMigrationState.java
