diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java index bab7ed0542402..645c804af2f8e 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java @@ -38,7 +38,6 @@ import lombok.extern.slf4j.Slf4j; import org.apache.bookkeeper.client.BookKeeper; import org.apache.bookkeeper.mledger.ManagedLedgerException; -import org.apache.pulsar.broker.PulsarService; import org.apache.pulsar.broker.ServiceConfiguration; import org.apache.pulsar.broker.web.PulsarWebResource; import org.apache.pulsar.broker.web.RestException; @@ -481,30 +480,6 @@ protected CompletableFuture getPartitionedTopicMetadat }); } - protected static PartitionedTopicMetadata fetchPartitionedTopicMetadata(PulsarService pulsar, TopicName topicName) { - try { - return pulsar.getBrokerService().fetchPartitionedTopicMetadataAsync(topicName).get(); - } catch (Exception e) { - if (e.getCause() instanceof RestException) { - throw (RestException) e.getCause(); - } - throw new RestException(e); - } - } - - protected static PartitionedTopicMetadata fetchPartitionedTopicMetadataCheckAllowAutoCreation( - PulsarService pulsar, TopicName topicName) { - try { - return pulsar.getBrokerService().fetchPartitionedTopicMetadataCheckAllowAutoCreationAsync(topicName) - .get(); - } catch (Exception e) { - if (e.getCause() instanceof RestException) { - throw (RestException) e.getCause(); - } - throw new RestException(e); - } - } - protected void validateClusterExists(String cluster) { try { if (!clusterResources().getCluster(cluster).isPresent()) {