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

Post a reply

Smilies
:) :( :oops: :chelo: :roll: :wink: :muza: :sorry: :angel: :read: *x) :clever:
View more smilies
BBCode is ON
[img] is ON
[flash] is OFF
[url] is ON
Smilies are ON
Topic review
   

Expand view Topic review: Anzahl der Partitionen eines Pulsar-Themas ermitteln: Konnte nicht in einen richtigen URI geparst werden, Schema fehlt

by Anonymous » 20 Dec 2024, 20:23

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.

Top