poorbarcode commented on PR #20927:
URL: https://github.com/apache/pulsar/pull/20927#issuecomment-1664384321
Additional context
```
2023-08-02T02:21:46,026+0000 [BookKeeperClientWorker-OrderedExecutor-0-0]
WARN org.apache.pulsar.broker.service.ServerCnx -
[/127.0.0.6:54641][persistent://sn/system/__xxx-partition-0][multiTopicsReader-3ec782c191]
Failed to create consumer: consumerId=0,
org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode =
ConnectionLoss for
/managed-ledgers/sn/system/persistent/__xxx-partition-0-multiTopicsReader-3ec782c191__transaction_pending_ack
java.util.concurrent.CompletionException:
org.apache.pulsar.metadata.api.MetadataStoreException:
org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode =
ConnectionLoss for
/managed-ledgers/sn/system/persistent/__xxx-partition-0-multiTopicsReader-3ec782c191__transaction_pending_ack
at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:332)
~[?:?]
at
java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1177)
~[?:?]
at
java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2309)
~[?:?]
at
org.apache.pulsar.broker.service.persistent.PersistentSubscription.addConsumer(PersistentSubscription.java:215)
~[io.streamnative-pulsar-broker-2.11.2.2.jar:2.11.2.2]
at
org.apache.pulsar.broker.service.AbstractTopic.addConsumerToSubscription(AbstractTopic.java:536)
~[io.streamnative-pulsar-broker-2.11.2.2.jar:2.11.2.2]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$internalSubscribe$16(PersistentTopic.java:785)
~[io.streamnative-pulsar-broker-2.11.2.2.jar:2.11.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.lambda$internalSubscribe$18(PersistentTopic.java:780)
~[io.streamnative-pulsar-broker-2.11.2.2.jar:2.11.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.internalSubscribe(PersistentTopic.java:701)
~[io.streamnative-pulsar-broker-2.11.2.2.jar:2.11.2.2]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.subscribe(PersistentTopic.java:677)
~[io.streamnative-pulsar-broker-2.11.2.2.jar:2.11.2.2]
at
org.apache.pulsar.broker.service.ServerCnx.lambda$handleSubscribe$11(ServerCnx.java:1135)
~[io.streamnative-pulsar-broker-2.11.2.2.jar:2.11.2.2]
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1150)
~[?:?]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
~[?:?]
at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147)
~[?:?]
at
org.apache.pulsar.broker.service.schema.BookkeeperSchemaStorage$Functions.lambda$getLedgerEntry$0(BookkeeperSchemaStorage.java:655)
~[io.streamnative-pulsar-broker-2.11.2.2.jar:2.11.2.2]
at
org.apache.bookkeeper.client.LedgerHandle$6.onSuccess(LedgerHandle.java:809)
~[org.apache.bookkeeper-bookkeeper-server-4.15.4.jar:4.15.4]
at
org.apache.bookkeeper.client.LedgerHandle$6.onSuccess(LedgerHandle.java:806)
~[org.apache.bookkeeper-bookkeeper-server-4.15.4.jar:4.15.4]
at
org.apache.bookkeeper.common.concurrent.FutureEventListener.accept(FutureEventListener.java:42)
~[org.apache.bookkeeper-bookkeeper-common-4.15.4.jar:4.15.4]
at
org.apache.bookkeeper.common.concurrent.FutureEventListener.accept(FutureEventListener.java:26)
~[org.apache.bookkeeper-bookkeeper-common-4.15.4.jar:4.15.4]
at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863)
~[?:?]
at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841)
~[?:?]
at
java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
~[?:?]
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.93.Final.jar:4.1.93.Final]
at java.lang.Thread.run(Thread.java:833) ~[?:?]
Caused by: org.apache.pulsar.metadata.api.MetadataStoreException:
org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode =
ConnectionLoss for
/managed-ledgers/sn/system/persistent/__xxx-partition-0-multiTopicsReader-3ec782c191__transaction_pending_ack
at
org.apache.pulsar.metadata.impl.ZKMetadataStore.getException(ZKMetadataStore.java:452)
~[io.streamnative-pulsar-metadata-2.11.2.2.jar:2.11.2.2]
at
org.apache.pulsar.metadata.impl.ZKMetadataStore.lambda$existsFromStore$11(ZKMetadataStore.java:331)
~[io.streamnative-pulsar-metadata-2.11.2.2.jar:2.11.2.2]
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)
~[?:?]
... 4 more
Caused by: org.apache.zookeeper.KeeperException$ConnectionLossException:
KeeperErrorCode = ConnectionLoss for
/managed-ledgers/sn/system/persistent/__xxx-partition-0-multiTopicsReader-3ec782c191__transaction_pending_ack
at
org.apache.zookeeper.KeeperException.create(KeeperException.java:102)
~[org.apache.zookeeper-zookeeper-3.8.1.jar:3.8.1]
at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
~[org.apache.zookeeper-zookeeper-3.8.1.jar:3.8.1]
at
org.apache.pulsar.metadata.impl.ZKMetadataStore.getException(ZKMetadataStore.java:442)
~[io.streamnative-pulsar-metadata-2.11.2.2.jar:2.11.2.2]
at
org.apache.pulsar.metadata.impl.ZKMetadataStore.lambda$existsFromStore$11(ZKMetadataStore.java:331)
~[io.streamnative-pulsar-metadata-2.11.2.2.jar:2.11.2.2]
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)
~[?:?]
... 4 more
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
