You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "HScarb (via GitHub)" <gi...@apache.org> on 2023/05/02 08:35:30 UTC
[GitHub] [rocketmq] HScarb opened a new issue, #6681: When pop consuming, it will not notify polling pop requests when new messages arrive at the retry topic
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: commits-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] When pop consuming, it will not notify polling pop requests when new messages arrive at the retry topic [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed issue #6681: When pop consuming, it will not notify polling pop requests when new messages arrive at the retry topic
URL: https://github.com/apache/rocketmq/issues/6681
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] When pop consuming, it will not notify polling pop requests when new messages arrive at the retry topic [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #6681:
URL: https://github.com/apache/rocketmq/issues/6681#issuecomment-2094507880
This issue was closed because it has been inactive for 3 days since being marked as stale.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] When pop consuming, it will not notify polling pop requests when new messages arrive at the retry topic [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #6681:
URL: https://github.com/apache/rocketmq/issues/6681#issuecomment-2089317489
This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org