This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git
The following commit(s) were added to refs/heads/main by this push:
new 2ba7150 [ISSUE #98] OffsetOption for SyncLiteSubscriptionRequest (#99)
2ba7150 is described below
commit 2ba715032dc75f05f38a21d5f00256ab8d3c7608
Author: Quan <[email protected]>
AuthorDate: Wed Dec 10 15:34:16 2025 +0800
[ISSUE #98] OffsetOption for SyncLiteSubscriptionRequest (#99)
---
apache/rocketmq/v2/definition.proto | 15 +++++++++++++++
apache/rocketmq/v2/service.proto | 1 +
2 files changed, 16 insertions(+)
diff --git a/apache/rocketmq/v2/definition.proto
b/apache/rocketmq/v2/definition.proto
index 2513bac..a0d3dfe 100644
--- a/apache/rocketmq/v2/definition.proto
+++ b/apache/rocketmq/v2/definition.proto
@@ -596,4 +596,19 @@ enum QueryOffsetPolicy {
// Use this option if time-based seek is targeted.
TIMESTAMP = 2;
+}
+
+message OffsetOption {
+ oneof offset_type {
+ Policy policy = 1;
+ int64 offset = 2;
+ int64 tail_n = 3;
+ int64 timestamp = 4;
+ }
+
+ enum Policy {
+ LAST = 0;
+ MIN = 1;
+ MAX = 2;
+ }
}
\ No newline at end of file
diff --git a/apache/rocketmq/v2/service.proto b/apache/rocketmq/v2/service.proto
index 136b3ee..2627581 100644
--- a/apache/rocketmq/v2/service.proto
+++ b/apache/rocketmq/v2/service.proto
@@ -329,6 +329,7 @@ message SyncLiteSubscriptionRequest {
// lite subscription set of lite topics
repeated string lite_topic_set = 4;
optional int64 version = 5;
+ optional OffsetOption offset_option = 6;
}
message SyncLiteSubscriptionResponse {
