Re: [D] Geo-replication with SSL [pulsar]

2024-04-27 Thread via GitHub 


GitHub user ragaur-tibco edited a discussion: Geo-replication with SSL

I was trying to setup the geo replication server and created clusters but after 
completing the geo-replication server with SSL
facing below error 

```
> java.util.concurrent.CompletionException: java.lang.RuntimeException: 
> java.lang.IllegalArgumentException: Param serviceUrl must not be blank.
>   at 
> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.uniApplyNow(CompletableFuture.java:687)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:662)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:2168) 
> ~[?:?]
>   at 
> org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$addReplicationCluster$72(PersistentTopic.java:1878)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1187)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2309)
>  ~[?:?]
>   at 
> org.apache.pulsar.broker.service.persistent.PersistentTopic.addReplicationCluster(PersistentTopic.java:1871)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.broker.service.persistent.PersistentTopic.initialize(PersistentTopic.java:352)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.broker.service.BrokerService$2.openLedgerComplete(BrokerService.java:1655)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl.lambda$asyncOpen$7(ManagedLedgerFactoryImpl.java:427)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:718)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147) 
> ~[?:?]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl$2.initializeComplete(ManagedLedgerFactoryImpl.java:394)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl$3$1.operationComplete(ManagedLedgerImpl.java:593)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedCursorImpl$2.operationComplete(ManagedCursorImpl.java:510)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedCursorImpl$2.operationComplete(ManagedCursorImpl.java:468)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.MetaStoreImpl.lambda$asyncGetCursorInfo$13(MetaStoreImpl.java:226)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:718)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
>  ~[?:?]
>   at 
> org.apache.bookkeeper.common.util.OrderedExecutor$TimedRunnable.run(OrderedExecutor.java:201)
>  ~[org.apache.bookkeeper-bookkeeper-common-4.16.4.jar:4.16.4]
>   at 
> org.apache.bookkeeper.common.util.SingleThreadSafeScheduledExecutorService$SafeRunnable.run(SingleThreadSafeScheduledExecutorService.java:46)
>  ~[org.apache.bookkeeper-bookkeeper-common-4.16.4.jar:4.16.4]
>   at 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
>   at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
>   at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
>  ~[?:?]
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
>  ~[?:?]
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
>  ~[?:?]
>   at 
> io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
>  ~[io.netty-netty-common-4.1.105.Final.jar:4.1.105.Final]
>   at java.lang.Thread.run(Thread.java:840) ~[?:?]
> Caused by: java.lang.RuntimeException: java.lang.IllegalArgumentException: 
> Param serviceUrl must not be blank.
>   at 
> org.apache.pulsar.broker.service.BrokerService.lambda$getReplicationClient$51(BrokerService.java:1316)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.put(ConcurrentOpenHashMap.java:438)
>  ~[org.apache.pulsar-pulsar-common-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.computeIfAbsent(ConcurrentOpenHashMap.java:257)
>

Re: [D] Geo-replication with SSL [pulsar]

2024-04-27 Thread via GitHub 


GitHub user ragaur-tibco edited a discussion: Geo-replication with SSL

I was trying to setup the geo replication server and created clusters but after 
completing the geo-replication server with SSL
facing below error 

```
> java.util.concurrent.CompletionException: java.lang.RuntimeException: 
> java.lang.IllegalArgumentException: Param serviceUrl must not be blank.
>   at 
> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.uniApplyNow(CompletableFuture.java:687)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:662)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:2168) 
> ~[?:?]
>   at 
> org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$addReplicationCluster$72(PersistentTopic.java:1878)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1187)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2309)
>  ~[?:?]
>   at 
> org.apache.pulsar.broker.service.persistent.PersistentTopic.addReplicationCluster(PersistentTopic.java:1871)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.broker.service.persistent.PersistentTopic.initialize(PersistentTopic.java:352)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.broker.service.BrokerService$2.openLedgerComplete(BrokerService.java:1655)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl.lambda$asyncOpen$7(ManagedLedgerFactoryImpl.java:427)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:718)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147) 
> ~[?:?]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl$2.initializeComplete(ManagedLedgerFactoryImpl.java:394)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl$3$1.operationComplete(ManagedLedgerImpl.java:593)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedCursorImpl$2.operationComplete(ManagedCursorImpl.java:510)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedCursorImpl$2.operationComplete(ManagedCursorImpl.java:468)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.MetaStoreImpl.lambda$asyncGetCursorInfo$13(MetaStoreImpl.java:226)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:718)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
>  ~[?:?]
>   at 
> org.apache.bookkeeper.common.util.OrderedExecutor$TimedRunnable.run(OrderedExecutor.java:201)
>  ~[org.apache.bookkeeper-bookkeeper-common-4.16.4.jar:4.16.4]
>   at 
> org.apache.bookkeeper.common.util.SingleThreadSafeScheduledExecutorService$SafeRunnable.run(SingleThreadSafeScheduledExecutorService.java:46)
>  ~[org.apache.bookkeeper-bookkeeper-common-4.16.4.jar:4.16.4]
>   at 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
>   at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
>   at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
>  ~[?:?]
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
>  ~[?:?]
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
>  ~[?:?]
>   at 
> io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
>  ~[io.netty-netty-common-4.1.105.Final.jar:4.1.105.Final]
>   at java.lang.Thread.run(Thread.java:840) ~[?:?]
> Caused by: java.lang.RuntimeException: java.lang.IllegalArgumentException: 
> Param serviceUrl must not be blank.
>   at 
> org.apache.pulsar.broker.service.BrokerService.lambda$getReplicationClient$51(BrokerService.java:1316)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.put(ConcurrentOpenHashMap.java:438)
>  ~[org.apache.pulsar-pulsar-common-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.computeIfAbsent(ConcurrentOpenHashMap.java:257)
>

Re: [D] Geo-replication with SSL [pulsar]

2024-04-27 Thread via GitHub 


GitHub user ragaur-tibco edited a discussion: Geo-replication with SSL

I was trying to setup the geo replication servers and created one cluster but 
after completing the geo-replication server with SSL
facing below error 

```
> java.util.concurrent.CompletionException: java.lang.RuntimeException: 
> java.lang.IllegalArgumentException: Param serviceUrl must not be blank.
>   at 
> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.uniApplyNow(CompletableFuture.java:687)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:662)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:2168) 
> ~[?:?]
>   at 
> org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$addReplicationCluster$72(PersistentTopic.java:1878)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1187)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2309)
>  ~[?:?]
>   at 
> org.apache.pulsar.broker.service.persistent.PersistentTopic.addReplicationCluster(PersistentTopic.java:1871)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.broker.service.persistent.PersistentTopic.initialize(PersistentTopic.java:352)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.broker.service.BrokerService$2.openLedgerComplete(BrokerService.java:1655)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl.lambda$asyncOpen$7(ManagedLedgerFactoryImpl.java:427)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:718)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147) 
> ~[?:?]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl$2.initializeComplete(ManagedLedgerFactoryImpl.java:394)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl$3$1.operationComplete(ManagedLedgerImpl.java:593)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedCursorImpl$2.operationComplete(ManagedCursorImpl.java:510)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.ManagedCursorImpl$2.operationComplete(ManagedCursorImpl.java:468)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> org.apache.bookkeeper.mledger.impl.MetaStoreImpl.lambda$asyncGetCursorInfo$13(MetaStoreImpl.java:226)
>  ~[org.apache.pulsar-managed-ledger-3.2.2.jar:3.2.2]
>   at 
> java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:718)
>  ~[?:?]
>   at 
> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
>  ~[?:?]
>   at 
> org.apache.bookkeeper.common.util.OrderedExecutor$TimedRunnable.run(OrderedExecutor.java:201)
>  ~[org.apache.bookkeeper-bookkeeper-common-4.16.4.jar:4.16.4]
>   at 
> org.apache.bookkeeper.common.util.SingleThreadSafeScheduledExecutorService$SafeRunnable.run(SingleThreadSafeScheduledExecutorService.java:46)
>  ~[org.apache.bookkeeper-bookkeeper-common-4.16.4.jar:4.16.4]
>   at 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
>   at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
>   at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
>  ~[?:?]
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
>  ~[?:?]
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
>  ~[?:?]
>   at 
> io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
>  ~[io.netty-netty-common-4.1.105.Final.jar:4.1.105.Final]
>   at java.lang.Thread.run(Thread.java:840) ~[?:?]
> Caused by: java.lang.RuntimeException: java.lang.IllegalArgumentException: 
> Param serviceUrl must not be blank.
>   at 
> org.apache.pulsar.broker.service.BrokerService.lambda$getReplicationClient$51(BrokerService.java:1316)
>  ~[org.apache.pulsar-pulsar-broker-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.put(ConcurrentOpenHashMap.java:438)
>  ~[org.apache.pulsar-pulsar-common-3.2.2.jar:3.2.2]
>   at 
> org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.computeIfAbsent(ConcurrentOpenHashMap.java:257)
>