Anzahl der Partitionen eines Pulsar-Themas ermitteln: Konnte nicht in einen richtigen URI geparst werden, Schema fehltJava

Java-Forum
Anonymous
 Anzahl der Partitionen eines Pulsar-Themas ermitteln: Konnte nicht in einen richtigen URI geparst werden, Schema fehlt

Post by Anonymous »

Ich kann die Anzahl der Partitionen eines Themas nicht über die PulsarAdmin-API ermitteln:
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))

Vorschläge zu diesem Fehler? Online hat nicht viel gebracht.

Ausnahme im Thread „main“
org.apache.pulsar.client.admin.PulsarAdminException:
java.lang.IllegalArgumentException:
pulsar+ssl://mypath.com:1234/admin/v2/persistent/abc/def/myplacev1/partitions
konnte nicht in eine richtige URI geparst werden, fehlendes Schema

Das Schema ist der Pulsar+SSL-Teil, afaik. Ich verstehe nicht, was an diesem Weg falsch ist.

Quick Reply

Change Text Case: 
   
  • Similar Topics
    Replies
    Views
    Last post