[ISSUE #98] OffsetOption for SyncLiteSubscriptionRequest (#99)

Author: f1amingo

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;
+  }
 }

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 {