[cleanup][broker]remove methods no longer used in AdminResource
@@ -38,7 +38,6 @@ import javax.ws.rs.core.Response.Status;
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 @@ public abstract class AdminResource extends PulsarWebResource {
});
}
- 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()) {
