HScarb opened a new issue, #6681: URL: https://github.com/apache/rocketmq/issues/6681
### Before Creating the Bug Report - [x] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq/discussions). - [x] I have searched the [GitHub Issues](https://github.com/apache/rocketmq/issues) and [GitHub Discussions](https://github.com/apache/rocketmq/discussions) of this repository and believe that this is not a duplicate. - [x] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ. ### Describe the Bug When pop consuming, it will not notify polling pop requests when new messages arrive at the retry topic. ### Steps to Reproduce 1. Create a topic `TopicTest`. 2. Start a pop push consumer using the example code `PopConsumer.java` to subscribe `TopicTest`, set popBatchSize to 1, and when receiving a message, print it and return `RECONSUME_LATER`. 3. Publish a message to `TopicTest`. 4. Wait and see the consumer's output ### What Did You Expect to See? The message should be consumed immediately after the first consumption and retry ### What Did You See Instead? After the first consumption, it takes about 15 seconds(which is the default polling timeout for pop push consumption) to consume the next time. ### What Version Are You Using? 5.1.1-SNAPSHOT ### Environment OS: Windows 11 Runtime: JDK8 ### Additional Context The output of the producer: ```log SendResult [sendStatus=SEND_OK, msgId=0A000008EBEC18B4AAC208B138D50000, offsetMsgId=7CDD4E5400002A9F0000000000020F1B, messageQueue=MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0], queueOffset=0] ``` The output of the consumer: ```log Consumer Started. ConsumeMessageThread_1 Receive New Messages: [MessageExt [brokerName=broker-a, queueId=0, storeSize=251, queueOffset=0, sysFlag=0, bornTimestamp=1683016232151, bornHost=/xxxxx:14768, storeTimestamp=1683016231717, storeHost=/xxxxx:10911, msgId=7CDD4E5400002A9F0000000000020F1B, commitLogOffset=134939, bodyCRC=198614610, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest2', flag=0, properties={CONSUME_START_TIME=1683016232195, MSG_REGION=DefaultRegion, 1ST_POP_TIME=1683016231719, UNIQ_KEY=0A000008EBEC18B4AAC208B138D50000, CLUSTER=DefaultCluster, POP_CK=0 1683016231719 60000 7 0 broker-a 0 0, TAGS=TagA, KEYS=OrderID188, WAIT=true, TRACE_ON=true}, body=[72, 101, 108, 108, 111, 32, 119, 111, 114, 108, 100], transactionId='null'}]] ConsumeMessageThread_2 Receive New Messages: [MessageExt [brokerName=broker-a, queueId=0, storeSize=324, queueOffset=0, sysFlag=0, bornTimestamp=1683016232151, bornHost=/xxxx:10911, storeTimestamp=1683016243756, storeHost=/xxxxx:10911, msgId=7CDD4E5400002A9F0000000000021715, commitLogOffset=136981, bodyCRC=198614610, reconsumeTimes=1, preparedTransactionOffset=0, toString()=Message{topic='TopicTest2', flag=0, properties={CONSUME_START_TIME=1683016247167, MSG_REGION=DefaultRegion, UNIQ_KEY=0A000008EBEC18B4AAC208B138D50000, CLUSTER=DefaultCluster, 1ST_POP_TIME=1683016231746, POP_CK=0 1683016246699 60000 2 1 broker-a 0 0, TAGS=TagA, KEYS=OrderID188, WAIT=true, TRACE_ON=true}, body=[72, 101, 108, 108, 111, 32, 119, 111, 114, 108, 100], transactionId='null'}]] ConsumeMessageThread_3 Receive New Messages: [MessageExt [brokerName=broker-a, queueId=0, storeSize=324, queueOffset=1, sysFlag=0, bornTimestamp=1683016232151, bornHost=/xxxxx:10911, storeTimestamp=1683016278793, storeHost=/xxxxx:10911, msgId=7CDD4E5400002A9F0000000000021FD5, commitLogOffset=139221, bodyCRC=198614610, reconsumeTimes=2, preparedTransactionOffset=0, toString()=Message{topic='TopicTest2', flag=0, properties={CONSUME_START_TIME=1683016279260, MSG_REGION=DefaultRegion, UNIQ_KEY=0A000008EBEC18B4AAC208B138D50000, CLUSTER=DefaultCluster, 1ST_POP_TIME=1683016231746, POP_CK=1 1683016278793 60000 0 1 broker-a 0 1, TAGS=TagA, KEYS=OrderID188, WAIT=true, TRACE_ON=true}, body=[72, 101, 108, 108, 111, 32, 119, 111, 114, 108, 100], transactionId='null'}]] ConsumeMessageThread_4 Receive New Messages: [MessageExt [brokerName=broker-a, queueId=0, storeSize=324, queueOffset=2, sysFlag=0, bornTimestamp=1683016232151, bornHost=/xxxx:10911, storeTimestamp=1683016341826, storeHost=/xxxxx:10911, msgId=7CDD4E5400002A9F00000000000234AC, commitLogOffset=144556, bodyCRC=198614610, reconsumeTimes=3, preparedTransactionOffset=0, toString()=Message{topic='TopicTest2', flag=0, properties={CONSUME_START_TIME=1683016354132, MSG_REGION=DefaultRegion, UNIQ_KEY=0A000008EBEC18B4AAC208B138D50000, CLUSTER=DefaultCluster, 1ST_POP_TIME=1683016231746, POP_CK=2 1683016353664 60000 3 1 broker-a 0 2, TAGS=TagA, KEYS=OrderID188, WAIT=true, TRACE_ON=true}, body=[72, 101, 108, 108, 111, 32, 119, 111, 114, 108, 100], transactionId='null'}]] ``` -- 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]
