cserwen opened a new issue #3491: URL: https://github.com/apache/rocketmq/issues/3491
**BUG REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? Consumers only consume messages and producers don't produce msgs. - What did you expect to see? Consumers consume msgs with a normal speed. - What did you see instead? - Consumers sometimes consume normally and sometimes are blocked. - Consume TPS is less then 200 and obviously there is a problem 2. Please tell us about your environment: Linux 3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc): I found that the reason may be related to `QueueLockManager` class. - Client send `pop-msg` request to broker. - Sometimes this request can success to get lock for queue, so return msgs immediately. But sometimes it can't get lock successfully，then the request will be put into `pollingMap`. - The requests in `pollingMap` will be executed when new msgs for this topic arriving or timeout. So for a topic，If no new msgs are produced, the consumers which subscribe it can't consume normally because their `pop-msg` requests may be held. -- 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]
