You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2020/11/19 07:22:46 UTC
[GitHub] [rocketmq] quwenzhe opened a new issue #2440: delay message consumption ahead of time
quwenzhe opened a new issue #2440:
URL: https://github.com/apache/rocketmq/issues/2440
[2020-11-19 10:15:39.118] [TID: N/A] [ConsumeMessageThread_2] INFO com.chehejia.iot.message.router.module.mq.producer.impl.RocketMQAsyncProducer sending message:Message [topic=IoT_System_Retry_Topic, flag=0, properties={mqtt-topic=veh/T181813KENGGPTYAUFA3/shadow, message-send-delay-queue-count=1, create-time=1605752139107, WAIT=true, DELAY=3}, body=156]
[2020-11-19 10:15:39.838] [TID: N/A] [ConsumeMessageThread_1] INFO com.chehejia.iot.message.router.module.mq.consumer.listener.RocketMQRetryListener com.chehejia.iot.message.router.module.mq.consumer.impl.RocketMQSlowConsumer retry message: MessageExt [queueId=0, storeSize=423, queueOffset=176543, sysFlag=0, bornTimestamp=1605752139836, bornHost=/172.21.142.41:54736, storeTimestamp=1605752139836, storeHost=/172.21.174.75:10911, msgId=AC15AE4B00002A9F00001776CF1AF921, commitLogOffset=25799048231201, bodyCRC=497580077, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message [topic=IoT_System_Retry_Topic, flag=0, properties={mqtt-topic=veh/T181813KENGGPTYAUFA3/shadow, MIN_OFFSET=174764, MAX_OFFSET=176544, CONSUME_START_TIME=1605752139838, create-time=1605752139107, UNIQ_KEY=0A15BF7A00015674CD4D5EE6203C37D9, CLUSTER=rocketmq-cluster-testtwo, WAIT=true}, body=156]]
producer send message at 10:15:39.118,and delayLevel is 3,but consumer receive the message at 10:15:39.838.
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [rocketmq] Jaskey commented on issue #2440: delay message consumption ahead of time
Posted by GitBox <gi...@apache.org>.
Jaskey commented on issue #2440:
URL: https://github.com/apache/rocketmq/issues/2440#issuecomment-733461189
It should not happens.
Please check
1. If they are the same message to make sure you don't get wrong conclusion.
2. Check your broker store congfg, what is you store level config, do you change it?
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [rocketmq] Jaskey edited a comment on issue #2440: delay message consumption ahead of time
Posted by GitBox <gi...@apache.org>.
Jaskey edited a comment on issue #2440:
URL: https://github.com/apache/rocketmq/issues/2440#issuecomment-733461189
It should not happens.
Please check
1. If they are the same message to make sure you don't get wrong conclusion.
2. Check your broker store config, what is you store level config, do you change it?
----------------------------------------------------------------
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:
users@infra.apache.org