文档首页/ 分布式消息服务Kafka版/ API参考/ API V2（推荐）/ 消费组管理/ 查询消费组消息位点
更新时间：2024-12-16 GMT+08:00
在线调试
CLI示例
查看PDF
分享

查询消费组消息位点

功能介绍

查询消费组消息位点。

调用方法

请参见如何调用API。

URI

GET /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}/message-offset

表1 路径参数

参数

是否必选

参数类型

描述

engine

是

String

消息引擎。

project_id

是

String

项目ID，获取方式请参见获取项目ID。

instance_id

是

String

实例ID。

group

是

String

消费组名称。
表2 Query参数

参数

是否必选

参数类型

描述

topic

是

String

topic名称。

partition

是

String

分区名称。

offset

是

String

偏移值。

limit

是

String

最大值。

请求参数

无

响应参数

状态码： 200

表3 响应Body参数

参数

参数类型

描述

group_message_offsets

Array of GroupMessageOffsetsDetailEntity objects

消费组消息位点详情

total

Integer

总数
表4 GroupMessageOffsetsDetailEntity

参数

参数类型

描述

partition

String

分区

message_current_offset

String

消息当前位点

message_log_start_offset

Integer

消息开始位点

message_log_end_offset

Integer

消息结束位点

consumer_id

String

消费者Id

host

String

host名称

client_id

String

客户端Id

请求示例

查询消费组消息位点

GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}/message-offset

响应示例

状态码： 200

查询成功

{
  "group_message_offsets" : [ ],
  "total" : 0
}

状态码

状态码

描述

200

查询成功

错误码

请参见错误码。

父主题： 消费组管理

相关文档