Description
Search before asking
- I searched in the issues and found nothing similar.
Read release policy
- I understand that unsupported versions don't get bug fixes. I will attempt to reproduce the issue on a supported version of Pulsar client and Pulsar broker.
Version
pulsar: 3.3.6
Minimal reproduce step
bin/pulsar-client consume -s test --regex test/test/t1:.*
bin/pulsar-client produce test/test/t1:t1 -m="{}"
What did you expect to see?
I expected to see the consumer successfully subscribe to the new topic t1:t1
What did you see instead?
currently the client watch list isn't receiving any response
Anything else?
The issue appears to occur during topic creation where the internal processing fails to perform URL decode operations on certain URL-encoded characters.
broker log:
2025-04-16T08:27:10,898+0000 [configuration-metadata-store-13-1] INFO org.apache.pulsar.broker.service.BrokerService - partitioned metadata successfully created for persistent://test/test/t1:t1
2025-04-16T08:27:11,353+0000 [pulsar-2-2] INFO org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - Opening managed ledger test/test/persistent/t1%3At1-partition-0
2025-04-16T08:27:11,357+0000 [bookkeeper-ml-scheduler-OrderedScheduler-0-0] INFO org.apache.bookkeeper.mledger.impl.MetaStoreImpl - Creating '/managed-ledgers/test/test/persistent/t1%3At1-partition-0'
2025-04-16T08:27:11,381+0000 [BookKeeperClientWorker-OrderedExecutor-0-0] INFO org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - [test/test/persistent/t1%3At1-partition-0] Created ledger 38943 after closed null
2025-04-16T08:27:11,387+0000 [bookkeeper-ml-scheduler-OrderedScheduler-0-0] INFO org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl - [test/test/persistent/t1%3At1-partition-0] Successfully initialize managed ledger
2025-04-16T08:27:11,388+0000 [broker-topic-workers-OrderedExecutor-0-0] INFO org.apache.pulsar.broker.service.BrokerService - Created topic persistent://test/test/t1:t1-partition-0 - dedup is disabled
2025-04-16T08:27:11,392+0000 [broker-topic-workers-OrderedExecutor-0-0] INFO org.apache.pulsar.broker.service.ServerCnx - [/10.80.0.222:33450] Created new producer: Producer{topic=PersistentTopic{topic=persistent://test/test/t1:t1-partition-0}, client=[id: 0x89d36a52, L:/10.80.2.17:6650 - R:/10.80.0.222:33450] [SR:10.80.0.222, state:Connected], producerName=pulsar-8-38, producerId=0}
2025-04-16T08:27:11,483+0000 [pulsar-io-3-1] INFO org.apache.pulsar.broker.service.ServerCnx - [PersistentTopic{topic=persistent://test/test/t1:t1-partition-0}][pulsar-8-38] Closing producer on cnx /10.80.0.222:33450. producerId=0
2025-04-16T08:27:11,483+0000 [pulsar-io-3-1] INFO org.apache.pulsar.broker.service.ServerCnx - [PersistentTopic{topic=persistent://test/test/t1:t1-partition-0}][pulsar-8-38] Closed producer on cnx /10.80.0.222:33450. producerId=0
2025-04-16T08:27:26,108+0000 [configuration-metadata-store-13-1] INFO org.eclipse.jetty.server.RequestLog - 10.80.1.217 - - [16/Apr/2025:08:27:26 +0000] "GET /admin/v2/persistent/test/test/t1%3At1/partitions HTTP/1.1" 200 32 "-" "Pulsar-Java-v2.7.0" 4
2025-04-16T08:27:26,177+0000 [pulsar-web-38-6] INFO org.eclipse.jetty.server.RequestLog - 10.80.1.217 - - [16/Apr/2025:08:27:26 +0000] "GET /admin/v2/persistent/test/test/t1%3At1/partitions HTTP/1.1" 200 32 "-" "Pulsar-Java-v2.7.0" 1
2025-04-16T08:27:26,506+0000 [pulsar-web-38-5] INFO org.eclipse.jetty.server.RequestLog - 10.80.1.217 - - [16/Apr/2025:08:27:26 +0000] "GET /admin/v2/persistent/test/test/t1%3At1/partitions HTTP/1.1" 200 32 "-" "Pulsar-Java-v2.7.0" 1
2025-04-16T08:27:30,148+0000 [pulsar-web-38-4] INFO org.eclipse.jetty.server.RequestLog - 10.80.0.222 - - [16/Apr/2025:08:27:30 +0000] "GET /admin/v2/persistent/test/test/t1%3At1-partition-0/stats?getPreciseBacklog=false&subscriptionBacklogSize=true&getEarliestTimeInBacklog=false&excludePublishers=false&excludeConsumers=false HTTP/1.1" 307 0 "-" "Pulsar-Java-v3.3.6" 2
2025-04-16T08:27:30,157+0000 [pulsar-web-38-6] INFO org.eclipse.jetty.server.RequestLog - 10.80.0.222 - - [16/Apr/2025:08:27:30 +0000] "GET /admin/v2/persistent/test/test/t1%3At1-partition-0/stats?excludePublishers=false&getPreciseBacklog=false&authoritative=true&subscriptionBacklogSize=true&getEarliestTimeInBacklog=false&excludeConsumers=false HTTP/1.1" 200 492 "-" "Pulsar-Java-v3.3.6" 1
Are you willing to submit a PR?
- I'm willing to submit a PR!