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 {