KAFKA-18384 Remove ZkAlterPartitionManager (#18364)

Reviewers: Mickael Maison <[email protected]>
apache · Jan 7, 2025 · 9d93a4f · 9d93a4f
1 parent abeed20
commit 9d93a4f
Show file tree

Hide file tree

Showing 5 changed files with 18 additions and 303 deletions.
diff --git a/core/src/main/scala/kafka/server/AlterPartitionManager.scala b/core/src/main/scala/kafka/server/AlterPartitionManager.scala
@@ -20,7 +20,6 @@ import java.util
 import java.util.concurrent.atomic.AtomicBoolean
 import java.util.concurrent.{CompletableFuture, ConcurrentHashMap}
 import kafka.utils.Logging
-import kafka.zk.KafkaZkClient
 import org.apache.kafka.clients.ClientResponse
 import org.apache.kafka.common.TopicIdPartition
 import org.apache.kafka.common.TopicPartition
@@ -100,17 +99,6 @@ object AlterPartitionManager {
       metadataVersionSupplier = () => metadataCache.metadataVersion()
     )
   }
-
-  /**
-   * Factory for ZK based implementation, used when IBP < 2.7-IV2
-   */
-  def apply(
-    scheduler: Scheduler,
-    time: Time,
-    zkClient: KafkaZkClient
-  ): AlterPartitionManager = {
-    new ZkAlterPartitionManager(scheduler, time, zkClient)
-  }
 }
 
 class DefaultAlterPartitionManager(

diff --git a/core/src/main/scala/kafka/server/ZkAlterPartitionManager.scala b/core/src/main/scala/kafka/server/ZkAlterPartitionManager.scala
diff --git a/core/src/main/scala/kafka/utils/ReplicationUtils.scala b/core/src/main/scala/kafka/utils/ReplicationUtils.scala