文档首页/ 分布式消息服务Kafka版/ API参考/ 历史API/ API V2/ 消息管理/ Kafka删除消息
更新时间：2025-12-30 GMT+08:00
查看PDF
分享

Kafka删除消息

功能介绍

Kafka删除消息。

当前页面API为历史版本API，未来可能停止维护。请使用删除Kafka消息。

URI

DELETE /v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/messages

表1 路径参数

参数

是否必选

参数类型

描述

project_id

是

String

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

instance_id

是

String

实例ID。

topic

是

String

Topic名称。

请求参数

表2 请求Body参数

参数

是否必选

参数类型

描述

partitions

否

Array of PartitionOffsetEntity objects

分区消费位点详情
表3 PartitionOffsetEntity

参数

是否必选

参数类型

描述

partition

否

Integer

分区

offset

否

Integer

消费位点

响应参数

状态码：200

表4 响应Body参数

参数

参数类型

描述

partitions

Array of PartitionResp objects

分区响应信息
表5 PartitionResp

参数

参数类型

描述

partition

Integer

分区

result

String

返回结果

error_code

String

返回错误码

请求示例

DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/messages

{
  "partitions" : [ {
    "partition" : 0,
    "offset" : 1
  } ]
}

响应示例

状态码：200

删除消息成功。

{
  "partitions" : [ {
    "partition" : 0,
    "result" : "success",
    "error_code" : 0
  } ]
}

状态码

状态码

描述

200

删除消息成功。

错误码

请参见错误码。

父主题： 消息管理