云服务器内容精选

华为云首页用户手册

消息查询

分布式消息服务KAFKA版-查询分区指定偏移量的消息:URI

URI GET /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/partitions/{partition}/message 表1 路径参数参数是否必选参数类型描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 topic 是 String Topic名称。 Topic名称必现以字母开头且只支持大小写字母、中横线、下划线以及数字。 partition 是 Integer 分区编号。表2 Query参数参数是否必选参数类型描述 message_offset 是 String 消息位置。

分布式消息服务KAFKA版消息查询
分布式消息服务KAFKA版-查询分区指定偏移量的消息:响应示例

响应示例状态码： 200 查询分区指定偏移量的消息成功。 { "message" : [ { "topic" : "mytest", "partition" : 0, "message_offset" : 7, "key" : null, "value" : "kasjdf", "size" : 6, "timestamp" : 1568125036045 } ] }

分布式消息服务KAFKA版消息查询
分布式消息服务KAFKA版-查询分区指定偏移量的消息:响应参数

响应参数状态码： 200 表3 响应Body参数参数参数类型描述 message Array of ShowPartitionMessageEntity objects 消息列表。表4 ShowPartitionMessageEntity 参数参数类型描述 key String 消息的key。 value String 消息内容。 topic String Topic名称。 partition Integer 分区编号。 message_offset Long 消息位置。 size Integer 消息大小，单位字节。 timestamp Long 生产消息的时间。格式为Unix时间戳。单位为毫秒。

分布式消息服务KAFKA版消息查询