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/12/19 13:56:41 UTC
[GitHub] [rocketmq] yejiahao opened a new issue #2279: scheduleMessageOffset overflow
yejiahao opened a new issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279
In my case, a strange phenomenon happens reported by ***tester engineer***:
**comsumer scheduleMessageOffset > producer scheduleMessageOffset**
- RocketMQ version is **V4.5.2** (Both client API and Server)
- broker status
```
sh /home/rocketMQ/rocketmq-4.5.2/bin/mqadmin brokerStatus -b <IP:PORT>
...
bootTimestamp : 1598590974120
brokerVersion : 317
brokerVersionDesc : V4_5_2
commitLogDirCapacity : Total : 258.2 GiB, Free : 130.9 GiB.
...
runtime : [ 2 days, 23 hours, 56 minutes, 36 seconds ]
scheduleMessageOffset_1 : 138699,447
scheduleMessageOffset_16 : 2,0
scheduleMessageOffset_2 : 5559,28
scheduleMessageOffset_3 : 538,4
scheduleMessageOffset_4 : 3,0
...
```
- producer client sample
```java
Message msg = new Message("topic", "tag", "body".getBytes(RemotingHelper.DEFAULT_CHARSET));
// 设置延迟消费级别
msg.setDelayTimeLevel(1);
// 等待存储完成后返回
msg.setWaitStoreMsgOK(true);
SendResult sendResult = producer.send(msg);
```
### Tester have restarted producer, consumer and rocketmq processor several times.
Because of scheduleMessageOffset overflow (@see mqadmin result), all of the producer which has **setDelayTimeLevel** cannot produce message in target topic, unless delay queue offset equals, e.g. ```scheduleMessageOffset_1 : 200,200```
Please feel free to contact. Thanks for your information.
----------------------------------------------------------------
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] RongtongJin closed issue #2279: scheduleMessageOffset overflow
Posted by GitBox <gi...@apache.org>.
RongtongJin closed issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279
----------------------------------------------------------------
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] francisoliverlee edited a comment on issue #2279: scheduleMessageOffset overflow
Posted by GitBox <gi...@apache.org>.
francisoliverlee edited a comment on issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279#issuecomment-688586364
can u reproduce it always or show how to reproduce 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] yejiahao commented on issue #2279: scheduleMessageOffset overflow
Posted by GitBox <gi...@apache.org>.
yejiahao commented on issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279#issuecomment-688589336
> can u reproduce it always ?
produce is ok but "topic" topic consume failed because of msg was stored in ```scheduleMessageOffset_'x'``` (x represents delayTimeLevel), it just change the offset like this
```
scheduleMessageOffset_1 : 138699,447
->
scheduleMessageOffset_1 : 138699,448
```
when it occurs
```
scheduleMessageOffset_1 : 138699,138699 (maybe 138700?)
```
the target topic consumer works normally and previous msgs also can be consumed
----------------------------------------------------------------
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] RongtongJin closed issue #2279: scheduleMessageOffset overflow
Posted by GitBox <gi...@apache.org>.
RongtongJin closed issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] RongtongJin commented on issue #2279: scheduleMessageOffset overflow
Posted by GitBox <gi...@apache.org>.
RongtongJin commented on issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279#issuecomment-748479579
@yejiahao I'm sorry I closed your issue. Could you provide more detailed information such as how to reproduce this issue？
----------------------------------------------------------------
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] francisoliverlee commented on issue #2279: scheduleMessageOffset overflow
Posted by GitBox <gi...@apache.org>.
francisoliverlee commented on issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279#issuecomment-688586364
can u reproduce it always ?
----------------------------------------------------------------
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] yejiahao commented on issue #2279: scheduleMessageOffset overflow
Posted by GitBox <gi...@apache.org>.
yejiahao commented on issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279#issuecomment-700382812
hehe
----------------------------------------------------------------
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] RongtongJin closed issue #2279: scheduleMessageOffset overflow
Posted by GitBox <gi...@apache.org>.
RongtongJin closed issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279
----------------------------------------------------------------
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] francisoliverlee commented on issue #2279: scheduleMessageOffset overflow
Posted by GitBox <gi...@apache.org>.
francisoliverlee commented on issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279#issuecomment-689260425
try
```
msg.setWaitStoreMsgOK(false);
```
----------------------------------------------------------------
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] RongtongJin closed issue #2279: scheduleMessageOffset overflow
Posted by GitBox <gi...@apache.org>.
RongtongJin closed issue #2279:
URL: https://github.com/apache/rocketmq/issues/2279
----------------------------------------------------------------
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