apache / pulsar

Apache Pulsar - distributed pub-sub messaging system
https://pulsar.apache.org/
Apache License 2.0
14.23k stars 3.58k forks source link

Producers and consumers throw PulsarClientException.AlreadyClosedException #13532

Open xuesongxs opened 2 years ago

xuesongxs commented 2 years ago

Describe the bug Pulsarclientexception is thrown by producer and consumer applications running in the online environment AlreadyClosedException. Pulsar v2.8.1

image image image

mattisonchao commented 2 years ago

Could you provide more information to help us to find problem?

xuesongxs commented 2 years ago

Could you provide more information to help us to find problem?

1.There is no error information in the broker's log. 2.allowAutoTopicCreation=false 3.The memory of zookeeper is set "-Xms2g -Xmx8g -XX:MaxDirectMemorySize=8g", and the GC pause time may reach 4s if the autopurge operation is performed once every 24 hours.

xuesongxs commented 2 years ago

When I tested the environment simulation, I found that if it was in broker.conf, allowAutoTopicCreation=false, use"bin/pulsar-perf consumer -q 10 -n 1-st shared -s consumersych persistent://public/default/test-string1” commad to test, then execute "bin/pulsar-admin topics delete partitioned topic -f persistent://public/default/test-string1", after that, pulsar perf throws an error similar to the online environment, but actually my online environment has not done any action. image

mattisonchao commented 2 years ago

I think i can work on it.

xuesongxs commented 2 years ago

I have a question about the conditions under which pulsarclientexception will be thrown AlreadyClosedException?

xuesongxs commented 2 years ago

Could you provide more information to help us to find problem? Now I use jmap dump to generate files. Can I add wechat to chat? wechat:daxia_xue

github-actions[bot] commented 2 years ago

The issue had no activity for 30 days, mark with Stale label.

github-actions[bot] commented 2 years ago

The issue had no activity for 30 days, mark with Stale label.