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/03/19 08:57:07 UTC

[GitHub] [rocketmq] yongliangcode opened a new issue #1869: delay message can't be consumed

yongliangcode opened a new issue #1869: delay message can't be consumed
URL: https://github.com/apache/rocketmq/issues/1869
 
 
   **BUG REPORT**
   
   1. Please describe the issue you observed:
   
   - What did you do (The steps to reproduce)?
   In our production environment，producer send delay message，but this message can not be consumed.
   
   Producer code 
   ` Message msg = new Message("my_test_topic",
                           value.getBytes(RemotingHelper.DEFAULT_CHARSET));
    msg.setKeys(key);
    msg.setDelayTimeLevel(4);
    SendResult sendResult = producer.send(msg);`
   
   - What did you expect to see?
   
   This message can be consumed correct.
   
   - What did you see instead?
   In the storeerror.log there are a lot of error message.
   `
   2020-03-18 16:38:06 WARN ScheduleMessageTimerThread - Offset not matched. Request offset: 509548460, firstOffset: 0, lastOffset: 6000000, mappedFileSize: 6000000, mappedFiles count: 1
   2020-03-18 16:38:06 WARN ScheduleMessageTimerThread - Offset not matched. Request offset: 665682360, firstOffset: 0, lastOffset: 6000000, mappedFileSize: 6000000, mappedFiles count: 1
   2020-03-18 16:38:07 WARN ScheduleMessageTimerThread - Offset not matched. Request offset: 509548460, firstOffset: 0, lastOffset: 6000000, mappedFileSize: 6000000, mappedFiles count: 1
   2020-03-18 16:38:07 WARN ScheduleMessageTimerThread - Offset not matched. Request offset: 665682360, firstOffset: 0, lastOffset: 6000000, mappedFileSize: 6000000, mappedFiles count: 1
   2020-03-18 16:38:07 WARN ScheduleMessageTimerThread - Offset not matched. Request offset: 509548460, firstOffset: 0, lastOffset: 6000000, mappedFileSize: 6000000, mappedFiles count: 1
   2020-03-18 16:38:07 WARN ScheduleMessageTimerThread - Offset not matched. Request offset: 665682360, firstOffset: 0, lastOffset: 6000000, mappedFileSize: 6000000, mappedFiles count: 1
   2020-03-18 16:38:07 WARN ScheduleMessageTimerThread - Offset not matched. Request offset: 509548460, firstOffset: 0, lastOffset: 6000000, mappedFileSize: 6000000, mappedFiles count: 1
   2020-03-18 16:38:07 WARN ScheduleMessageTimerThread - Offset not matched. Request offset: 665682360, firstOffset: 0, lastOffset: 6000000, mappedFileSize: 6000000, mappedFiles count: 1
   `
   2. Please tell us about your environment:
   Our production environment. RocketMQ 4.5.2；But other rocketmq cluster of this version run ok.
   
   3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):
   After remove file "consumequeue/SCHEDULE_TOPIC_XXXX" and remove "config/delayOffset.json" file, restart the broker,  delay message restore, consume correctly. 
   
   Reference event review process：
   [https://mp.weixin.qq.com/s/f27tcOlm0_BTvL8725RPTQ](click here)
   
   
   

----------------------------------------------------------------
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


With regards,
Apache Git Services

[GitHub] [rocketmq] xujianhai666 commented on issue #1869: delay message can't be consumed

Posted by GitBox <gi...@apache.org>.
xujianhai666 commented on issue #1869: delay message can't be consumed
URL: https://github.com/apache/rocketmq/issues/1869#issuecomment-602375649
 
 
   @yongliangcode did u delete firstly and then producer send message?

----------------------------------------------------------------
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


With regards,
Apache Git Services

[GitHub] [rocketmq] xujianhai666 removed a comment on issue #1869: delay message can't be consumed

Posted by GitBox <gi...@apache.org>.
xujianhai666 removed a comment on issue #1869: delay message can't be consumed
URL: https://github.com/apache/rocketmq/issues/1869#issuecomment-602375649
 
 
   @yongliangcode did u delete firstly and then producer send message?

----------------------------------------------------------------
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


With regards,
Apache Git Services