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

Kafka生产消息

功能介绍

在控制台发送指定消息到Kafka实例。

URI

POST /v2/{project_id}/instances/{instance_id}/messages/action

表1 路径参数

参数

是否必选

参数类型

描述

project_id

是

String

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

instance_id

是

String

实例ID
表2 Query参数

参数

是否必选

参数类型

描述

action_id

是

String

动作ID，生产消息对应的action_id为send。

请求参数

表3 请求Body参数

参数

是否必选

参数类型

描述

topic

是

String

Kafka的Topic

body

是

String

消息内容

property_list

是

Array of property_list objects

Topic的分区信息等
表4 property_list

参数

是否必选

参数类型

描述

name

否

String

特性名字

value

否

String

特性值

响应参数

状态码：200

表5 响应Body参数

参数

参数类型

描述

topic

String

Kafka的Topic

body

String

消息内容

property_list

Array of objects

Topic的分区信息等

请求示例

Kafka控制台发送消息

POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/messages/action?action_id={action_id}

{
  "topic" : "XXXX",
  "body" : "hello world",
  "property_list" : [ {
    "name" : "KEY",
    "value" : "testKey"
  }, {
    "name" : "PARTITION",
    "value" : "0"
  } ]
}

响应示例

状态码：200

生产消息成功

{
  "topic" : "XXXX",
  "body" : "XXXX",
  "property_list" : [ ]
}

状态码

状态码

描述

200

生产消息成功

错误码

请参见错误码。

父主题： 主题管理