I'm unable to get the number of partitions from a topic via the PulsarAdmin API:
val admin: PulsarAdmin =
PulsarAdmin
.builder()
.authentication(authParams)
.serviceHttpUrl(serviceUrl)
.tlsTrustCertsFilePath(tlsTrustCertsFilePath)
.allowTlsInsecureConnection(tlsAllowInsecureConnection)
.build()
println(containerProperties.pulsarContainerBuilderProperties.serviceUrl)
println(authParams) // params seem fine...
// Error here: can't get number of partitions
println(admin.topics().getPartitionedTopicMetadata(inputTopic))
Suggestions on this error? Online did not yield much.
Exception in thread "main" org.apache.pulsar.client.admin.PulsarAdminException: java.lang.IllegalArgumentException: pulsar+ssl://mypath.com:1234/admin/v2/persistent/abc/def/myplacev1/partitions could not be parsed into a proper Uri, missing scheme