apache / pulsar

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

[Transactions] After closing consumers or readers there are still many topics named "xxx_transaction_pending_ack" #11000

Closed eolivelli closed 1 year ago

eolivelli commented 3 years ago

I am running tests against Pulsar 2.8.0 and I am seeing that my test environment is full of topics named like: the names include some Non durable "subscription name" that has been closed and also subscription names that a durable. I am expecting those topics to be deleted when the subscription is deleted

"persistent://public/default/MY_TOPIC-23598268-caa7-45a7-95f2-dcccc962f2ae__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-67896afe-1f90-428c-a342-7899888ecf02__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-95537162db__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-9b4643cc50__transaction_pending_ack"
"persistent://public/default/__transaction_buffer_snapshot"
"persistent://public/default/MY_QUEUE-reader-96ea29ad47__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-cts_DurableSubscriberNoLocal__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-cts_DurableSubscriberSelect__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-55afebfaab__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-02ab75f816__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-5d43bff9-6d1c-4846-bff7-d8a3ccabc6f2__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-fde13e5f-78d9-45c8-9a60-3e4c7176b9b5__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-fb47901fc9__transaction_pending_ack"
"persistent://public/default/Q2-jms-queue__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-c6216f2da5__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-48c0ac2c-a543-4e6b-930c-7e77465d5d92__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-618a8d1870__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-45daaeb97f__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-5bf70d0966__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-742ab034b5__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-9e0c72de-f963-4883-b547-7d0bf5d60976__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-7b9b75ebfe__transaction_pending_ack"
"persistent://public/default/Q2"
"persistent://public/default/MY_TOPIC-f031291d-a9ce-4d76-bff0-227135448626__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-cts_DurableSubscriberDefault__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-e28892ffb6__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-e1db9e50a6__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-e723ea5677__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-jms-queue__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-162279bdb5__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-8d385cbd-3e3b-49fb-a914-02cc14ae2975__transaction_pending_ack"
"persistent://public/default/MY_QUEUE"
"persistent://public/default/MY_QUEUE-reader-c5ea843aca__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-104b29e3-8e23-413a-b842-9632186a41d8__transaction_pending_ack"
"persistent://public/default/Q2-reader-a3f2890982__transaction_pending_ack"
"persistent://public/default/MY_TOPIC-57c74a31-50db-44ad-9859-da90f8c6f246__transaction_pending_ack"
"persistent://public/default/MY_QUEUE-reader-b71d095304__transaction_pending_ack"
codelipenghui commented 2 years ago

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

tisonkun commented 1 year ago

Closing as stale. If it's still relevant to maintained versions, feel free to open a new issue