0

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

0

Browse other questions tagged or ask your own question.