jinxiaoyi opened a new issue, #20813: URL: https://github.com/apache/pulsar/issues/20813
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version pulsar-clinet 2.10.4 pulsar-server 2.10.1 ### Minimal reproduce step i use pulsar-manage create topic with 2 partitions i start java application with 5 topics(topic1,topic2,topic3,topic4,topic5) one topic use one consumer set listenerThreads=10 set topic1 mode=KeyShared topic1 bind consumer1 use messageListener i send 50 messages to topic1 ### What did you expect to see? result should be 2 threads because topic1 use one consumer with 2 partitions。 48 messages should wait ### What did you see instead? 10 threads works at the same time。 40messages wait ### Anything else? _No response_ ### Are you willing to submit a PR? - [X] I'm willing to submit a PR! -- 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]
