lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.905 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.906

@@ -7011,9 +7011,68 @@
           end
           @RequestId = params['RequestId']
         end
       end
 
+      # FetchMessageListByTimestamp请求参数结构体
+      class FetchMessageListByTimestampRequest < TencentCloud::Common::AbstractModel
+        # @param InstanceId: 实例Id
+        # @type InstanceId: String
+        # @param Topic: 主题名
+        # @type Topic: String
+        # @param Partition: 分区id
+        # @type Partition: Integer
+        # @param StartTime: 查询开始时间，13位时间戳
+        # @type StartTime: Integer
+        # @param SinglePartitionRecordNumber: 最大查询条数，默认20，最大20
+        # @type SinglePartitionRecordNumber: Integer
+
+        attr_accessor :InstanceId, :Topic, :Partition, :StartTime, :SinglePartitionRecordNumber
+
+        def initialize(instanceid=nil, topic=nil, partition=nil, starttime=nil, singlepartitionrecordnumber=nil)
+          @InstanceId = instanceid
+          @Topic = topic
+          @Partition = partition
+          @StartTime = starttime
+          @SinglePartitionRecordNumber = singlepartitionrecordnumber
+        end
+
+        def deserialize(params)
+          @InstanceId = params['InstanceId']
+          @Topic = params['Topic']
+          @Partition = params['Partition']
+          @StartTime = params['StartTime']
+          @SinglePartitionRecordNumber = params['SinglePartitionRecordNumber']
+        end
+      end
+
+      # FetchMessageListByTimestamp返回参数结构体
+      class FetchMessageListByTimestampResponse < TencentCloud::Common::AbstractModel
+        # @param Result: 返回结果。注意，列表中不返回具体的消息内容（key、value），如果需要查询具体消息内容，请使用FetchMessageByOffset接口
+        # @type Result: Array
+        # @param RequestId: 唯一请求 ID，由服务端生成，每次请求都会返回（若请求因其他原因未能抵达服务端，则该次请求不会获得 RequestId）。定位问题时需要提供该次请求的 RequestId。
+        # @type RequestId: String
+
+        attr_accessor :Result, :RequestId
+
+        def initialize(result=nil, requestid=nil)
+          @Result = result
+          @RequestId = requestid
+        end
+
+        def deserialize(params)
+          unless params['Result'].nil?
+            @Result = []
+            params['Result'].each do |i|
+              consumerrecord_tmp = ConsumerRecord.new
+              consumerrecord_tmp.deserialize(i)
+              @Result << consumerrecord_tmp
+            end
+          end
+          @RequestId = params['RequestId']
+        end
+      end
+
       # 数据处理——处理链
       class FieldParam < TencentCloud::Common::AbstractModel
         # @param Analyse: 解析
         # @type Analyse: :class:`Tencentcloud::Ckafka.v20190819.models.AnalyseParam`
         # @param SecondaryAnalyse: 二次解析