apache
diff --git a/‎core/src/main/scala/kafka/server/AlterPartitionManager.scala‎
Lines changed: 0 additions & 12 deletions b/‎core/src/main/scala/kafka/server/AlterPartitionManager.scala‎
Lines changed: 0 additions & 12 deletions
diff --git a/‎core/src/main/scala/kafka/server/ZkAlterPartitionManager.scala‎
Lines changed: 0 additions & 111 deletions b/‎core/src/main/scala/kafka/server/ZkAlterPartitionManager.scala‎
Lines changed: 0 additions & 111 deletions
diff --git a/‎core/src/main/scala/kafka/utils/ReplicationUtils.scala‎
Lines changed: 0 additions & 58 deletions b/‎core/src/main/scala/kafka/utils/ReplicationUtils.scala‎
Lines changed: 0 additions & 58 deletions
@@ -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(