We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4e9574a commit f56cea9Copy full SHA for f56cea9
store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStoreInterface.java
@@ -38,6 +38,12 @@ public interface ConsumeQueueStoreInterface {
38
*/
39
void recover(boolean concurrently) throws RocksDBException;
40
41
+ /**
42
+ * Get the dispatch offset in consume queue store, messages whose phyOffset larger than this offset need
43
+ * to be dispatched. The dispatch offset only used in recover.
44
+ *
45
+ * @return the dispatch phyOffset
46
+ */
47
long getDispatchFromPhyOffset();
48
49
/**
0 commit comments