From b398d6f420541b65deadf35a364bc7b94e9277df Mon Sep 17 00:00:00 2001
From: Quan <zsjperiod@foxmail.com>
Date: Wed, 10 Dec 2025 13:44:25 +0800
Subject: [PATCH 1/2] OffsetOption for SyncLiteSubscriptionRequest

Change-Id: Iafcd4774da6c278f6a4ee4e1337881d8b6d73f1a
---
 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..4cccb8a 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 {
+    Special special = 1;
+    int64 offset = 2;
+    int64 last_n = 3;
+    int64 timestamp = 4;
+  }
+
+  enum Special {
+    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 {

From 1fa095c8b5a8950f23726f933e85670c9890ba7f Mon Sep 17 00:00:00 2001
From: Quan <zsjperiod@foxmail.com>
Date: Wed, 10 Dec 2025 15:29:13 +0800
Subject: [PATCH 2/2] rename field

Change-Id: I2d32aee89157440ecee939185de8a7d6af4bc4d2
---
 apache/rocketmq/v2/definition.proto | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/apache/rocketmq/v2/definition.proto b/apache/rocketmq/v2/definition.proto
index 4cccb8a..a0d3dfe 100644
--- a/apache/rocketmq/v2/definition.proto
+++ b/apache/rocketmq/v2/definition.proto
@@ -600,13 +600,13 @@ enum QueryOffsetPolicy {
 
 message OffsetOption {
   oneof offset_type {
-    Special special = 1;
+    Policy policy = 1;
     int64 offset = 2;
-    int64 last_n = 3;
+    int64 tail_n = 3;
     int64 timestamp = 4;
   }
 
-  enum Special {
+  enum Policy {
     LAST = 0;
     MIN = 1;
     MAX = 2;