Class PulsarAdminConfig

java.lang.Object
io.numaproj.pulsar.config.admin.PulsarAdminConfig

public final class PulsarAdminConfig extends Object
Builds a PulsarAdmin from configuration.
  • Method Details

    • create

      public static org.apache.pulsar.client.admin.PulsarAdmin create(PulsarAdminProperties pulsarAdminProperties) throws org.apache.pulsar.client.api.PulsarClientException
      Builds a PulsarAdmin from the supplied properties.
      Parameters:
      pulsarAdminProperties - parsed pulsar.admin config
      Returns:
      the admin client
      Throws:
      IllegalStateException - if the admin config is empty
      org.apache.pulsar.client.api.PulsarClientException - if the admin client cannot be built