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.
Anzahl der Partitionen eines Pulsar-Themas ermitteln: Konnte nicht in einen richtigen URI geparst werden, Schema fehlt ⇐ Java
-
- Similar Topics
- Replies
- Views
- Last post