检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
broker注册时间,为unix时间戳格式。 is_health Boolean Kafka实例节点的连通性是否正常。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/cluster
String 错误码。 error_msg String 错误描述。 请求示例 创建一个用户,用户名为test,密码为Cxxx3。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/users { "user_name"
accumulated_partitions Integer 该次诊断任务发现的存在消息堆积的分区数 请求示例 查询消息积压诊断报告列表。 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks
static_config Integer 本次修改静态配置参数个数。 请求示例 修改实例的连接空闲超时和日志删除的时间阈值。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/configs { "kafka_configs"
Integer 诊断结论ID params Map<String,String> 诊断结论参数列表 请求示例 查询诊断报告详情。 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-
Integer 消息大小,单位字节。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
修改broker跨VPC访问的状态。 ip String listeners IP。 请求示例 修改实例跨VPC访问的内网IP。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/crossvpc/modify
String 实例转储ID。 请求示例 新规格按需实例的开启Smart Connect,设置Smart Connect节点数量为2。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector {
p。 message_offset、timestamp二者必选其一。 响应参数 无 请求示例 重置的消费进度到指定偏移量。 POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/groups/{
参数说明见表2。 表2 参数说明 参数 类型 是否必选 说明 topics Array 是 待删除的topic列表 请求示例 POST https://{dms_endpoint}/v1.0/{project_id}/instances/{instance_id}/topics/delete
partition Integer 分区 result String 返回结果 error_code String 返回错误码 请求示例 DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/messages
Integer 租户最大可以创建的实例个数,或者每个实例最大可以创建的标签个数。 used Integer 已创建的实例个数。 请求示例 GET https://{endpoint}/v1.0/{project_id}/quotas/dms 响应示例 状态码: 200 查询成功。 { "quotas"
消息内容 property_list Array of objects topic的分区信息等 请求示例 Kafka控制台发送消息 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/messages/action
message_current_offset Long 当前消费进度。 message_log_end_offset Long 最大消息位置(LEO)。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}
该副本当前日志大小。单位:Byte。 lag Long 该副本当前落后hw的消息数。 请求示例 查询指定Topic的详细信息。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/topics/{topic}
topic_partition String 分区。 percentage Double 磁盘使用量的占比。 请求示例 查询Topic的磁盘存储情况 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/diskusage
消费者Id host String host名称 client_id String 客户端Id 请求示例 查询消费组消息位点 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/group
error_code String 错误码。 error_msg String 错误描述。 请求示例 升级id为instance_id的实例。 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/upgrade
查询维护时间窗开始时间和结束时间。 URI GET /v1.0/instances/maintain-windows 请求消息 请求参数 无。 请求示例 GET https://{dms_endpoint}/v1.0/instances/maintain-windows 响应消息 响应参数 参数说明见表表1、表2
error_msg String 错误描述。 请求示例 设置用户权限,为root用户授予发布和订阅topic-test的权限。 POST https://{endpoint}/v1/{project_id}/instances/{instance_id}/topics/accesspolicy