lirong-Lee commented on issue #340: URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-751959289
The problem is: if a CPushConsumer is permanently closed, it may cause some messages to be delayed for half an hour. The specific operation is： 1、Two clients A and B CLUSTERING subscribe to a topic, and a Producer continuously pushes it. 2、When A receives a message, kill A 3、observe whether the message is pushed to B. If it is pushed to B, pull up A 4、Repeat 2 and 3 operations 5、After repeating operations 2 and 3 several times, turn off A, B will not receive a lot of messages 6、The news is piled up on the broker, and then pushed to B after half an hour My broker uses rocketmq-4.7.1, this operation is complete. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
