文档首页/ 分布式消息服务Kafka版/ API参考（吉隆坡区域）/ API V2（推荐）/ 主题管理/ 查询Topic的当前生产者列表
更新时间：2025-09-03 GMT+08:00
在线调试
CLI示例
查看PDF
分享

查询Topic的当前生产者列表

功能介绍

查询Topic的当前生产者列表。

URI

GET /v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/producers

表1 路径参数

参数

是否必选

参数类型

描述

project_id

是

String

参数解释：

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

约束限制：

不涉及。

取值范围：

不涉及。

默认取值：

不涉及。

instance_id

是

String

参数解释：

实例ID。获取方法如下：调用“查询所有实例列表”接口，从响应体中获取实例ID。

约束限制：

不涉及。

取值范围：

不涉及。

默认取值：

不涉及。

topic

是

String

参数解释：

主题。

约束限制：

不涉及。

取值范围：

不涉及。

默认取值：

不涉及。
表2 Query参数

参数

是否必选

参数类型

描述

offset

否

Integer

参数解释：

偏移量，表示查询该偏移量后面的记录。

约束限制：

不涉及。

取值范围：

大于等于0。

默认取值：

不涉及。

limit

否

Integer

参数解释：

查询返回记录的数量限制。

约束限制：

不涉及。

取值范围：

1~50。

默认取值：

不涉及。

请求参数

无

响应参数

状态码：200

表3 响应Body参数

参数

参数类型

描述

total

Integer

参数解释：

总条数。

取值范围：

0~10000。

producers

Array of producers objects

参数解释：

生产者列表。
表4 producers

参数

参数类型

描述

producer_address

String

参数解释：

生产者地址。

取值范围：

不涉及

broker_address

String

参数解释：

broker地址。

取值范围：

不涉及

join_time

Long

参数解释：

加入时间，以Unix时间戳显示。

取值范围：

不涉及

请求示例

查询Topic的当前生产者列表

GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/producers?offset=0&limit=10

响应示例

状态码：200

查询topic的当前生产者列表成功

{
  "total" : 3,
  "producers" : [ {
    "producer_address" : "192.0.0.149:40443",
    "broker_address" : "192.0.0.146:9092",
    "join_time" : 1687204743328
  }, {
    "producer_address" : "192.0.0.149:13807",
    "broker_address" : "192.0.0.80:9092",
    "join_time" : 1687204745939
  }, {
    "producer_address" : "192.0.0.149:31876",
    "broker_address" : "192.0.0.71:9092",
    "join_time" : 1687204744934
  } ]
}

状态码

状态码

描述

200

查询topic的当前生产者列表成功

错误码

请参见错误码。

父主题： 主题管理