检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
是否为默认可用区。 remain_time Long 剩余时间。 ipv6_enable Boolean 是否支持IPv6。 请求示例 GET https://{endpoint}/v2/available-zones 响应示例 状态码： 200 查询可用区信息成功。 查询实例成功返回示例如下。
result String 执行结果。 instance_id String 实例ID。 请求示例 重启Kafka Manager。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/restart-kafka-manager
default_app Boolean 是否为默认应用。 created_time Long 创建时间。 请求示例 查询用户列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/users 响应示例 状态码：
Integer 最新消息位置。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
Integer 最新消息位置。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
Integer 协调器编号。 group_desc String 消费组描述。 lag Long 堆积数。 请求示例 查询消费组列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups?offest=
broker_address String broker地址 join_time Long 加入时间 请求示例 查询Topic的当前生产者列表 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/producers
权限类型。 all：拥有发布、订阅权限; pub：拥有发布权限; sub：拥有订阅权限。 请求示例 查询Topic的用户权限。 GET https://{endpoint}/v1/{project_id}/instances/{instance_id}/topics/{topic_name}/accesspolicy
描述 id String Topic名称。 success Boolean 是否删除成功。 请求示例 批量删除Topic。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/delete
users 否 Array of strings 用户列表。 当删除用户时，为必选参数。 响应参数 无 请求示例 批量删除用户。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/users { "action"
report_id String 诊断报告ID。 请求示例 创建消费组group-test，主题topic-test的消息积压诊断任务 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks
error_code String 错误码。 error_msg String 错误描述。 请求示例 编辑一个消费组，消费组描述为desc。 PUT https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/groups/test
与开源Kafka的差异 分布式消息服务Kafka版在兼容开源Kafka基础上，对版本特性做了一定程度的定制和增强，所以，除了拥有开源Kafka的优点，分布式消息服务Kafka版提供了更多可靠、实用的特性。 表1 分布式消息服务Kafka版与开源Kafka的差异说明 对比类 对比项
String 删除失败的消费组ID。 error_message String 删除失败的原因。 请求示例 批量删除消费组。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups/batch-delete
message_count Long 分区消息数 last_update_time Long 最近更新时间 请求示例 查询topic的分区列表 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/partitions
String 任务状态。 created_at String 启动时间。 updated_at String 结束时间。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/tasks/{task_id}
错误码。 error_msg String 错误描述。 请求示例 对消费组group-1所订阅的topic-1进行消息积压诊断预检查 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/diagnosis-check
Integer 消息大小，单位字节。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
参数类型 描述 result Boolean 报告删除结果 id String 报告ID 请求示例 批量删除消息积压诊断报告。 DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks
broker注册时间，为unix时间戳格式。 is_health Boolean Kafka实例节点的连通性是否正常。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/cluster
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
