Код: Выделить всё
val admin: PulsarAdmin =
PulsarAdmin
.builder()
.authentication(authParams)
.serviceHttpUrl(serviceUrl)
.tlsTrustCertsFilePath(tlsTrustCertsFilePath)
.allowTlsInsecureConnection(tlsAllowInsecureConnection)
.build()
println(serviceUrl)
println(authParams) // params seem fine...
// Error here: can't get number of partitions
println(admin.topics().getPartitionedTopicMetadata(inputTopic))
Исключение в потоке «main»
org.apache.pulsar.client.admin.PulsarAdminException:
java.lang.IllegalArgumentException:
pulsar+ssl://mypath.com:1234/admin/v2/persistent/abc/def/myplacev1/partitions
невозможно разобрать правильный Uri, отсутствует схема
На самом деле схема представляет собой часть pulsar+ssl. Я не понимаю, что не так с этим путем.
Подробнее здесь: https://stackoverflow.com/questions/792 ... to-a-prope