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 2022/08/25 09:49:14 UTC
[GitHub] [rocketmq] lizhanhui opened a new issue, #4890: Binary binary search consume queue offset by timestamp
lizhanhui opened a new issue, #4890:
URL: https://github.com/apache/rocketmq/issues/4890
There are use cases, where we need to pinpoint offset in consume queue by the given timestamp—for example, count the number of messages for a given message queue in the given time range.
Current implementation fails in multiple ways,
1. It ignores the fact that for a given millisecond(our clock resolution in storage), there may exist several messages as depicted below
```text
/*
* --------------------------
* timestamp Consume Queue
* t1 1
* t1 2
* t1 3
* t3 4
* t3 5
* --------------------------
*/
```
2. For the exemplified use case, we need to further specify the lookup strategy: if there are multiple messages matching the given timepoint, which one is expected? the upper or the lower?
3. If the same timepoint messages span two consume queue mapped files, the current solution is also inaccurate.
--
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.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] RongtongJin closed issue #4890: Binary binary search consume queue offset by timestamp
Posted by "RongtongJin (via GitHub)" <gi...@apache.org>.
RongtongJin closed issue #4890: Binary binary search consume queue offset by timestamp
URL: https://github.com/apache/rocketmq/issues/4890
--
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