检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
响应Body参数 参数 参数类型 描述 error_code String 错误码。 error_msg String 错误描述。 状态码：403 表6 响应Body参数 参数 参数类型 描述 error_code String 错误码。 error_msg String 错误描述。
response, err := client.BatchDeleteGroup(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
未开启SASL： ./kafka-consumer-groups.sh --bootstrap-server {connection-address} --describe --group {group-name} 已开启SASL： ./kafka-consumer-groups.sh --bootstrap-server
response, err := client.DeleteSinkTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
预检查失败原因 success Boolean 预检查是否正常 状态码：400 表5 响应Body参数 参数 参数类型 描述 error_code String 错误码。 error_msg String 错误描述。 请求示例 对消费组group-1所订阅的topic-1进行消息积压诊断预检查
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 偏移量，表示查询该偏移量后面的记录 limit 否 Integer 查询返回记录的数量限制 请求参数 无 响应参数 状态码：200 表3
instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 偏移量，表示从此偏移量开始查询， offset大于等于0。 limit 否 Integer 当次查询返回的最大消费组id个数，默认值为10，取值范围为1~50。
2u4g.cluster.small 3~30 20000 100 15 2000 300~300000 40 kafka.2u4g.cluster 3~30 30000 250 20 2000 300~300000 100 kafka.4u8g.cluster 3~30 100000
参数类型 描述 job_id String 配置修改任务ID。 dynamic_config Integer 本次修改动态配置参数个数。 static_config Integer 本次修改静态配置参数个数。 请求示例 修改实例的连接空闲超时和日志删除的时间阈值。 PUT http
Kafka实例节点 1分钟 broker_fetch_mean 消费请求平均处理时长 统计Broker节点处理消费请求平均时长。 0~10000 ms 不涉及 Kafka实例节点 1分钟 broker_produce_mean 生产请求平均处理时长 统计Broker节点处理生产请求平均时长。
表明请求超出了客户端访问频率的限制或者服务端接收到多于它能处理的请求。建议客户端读取相应的Retry-After首部，然后等待该首部指出的时间后再重试。 500 InternalServerError 表明服务端能被请求访问到，但是不能理解用户的请求。 501 Not Implemented
listeners IP/域名”列，单击，切换到域名模式。将“advertised.listeners IP/域名”修改为7和8中记录的内网域名。内网域名必须与Port ID一一对应，否则会导致网络不通。 图8 修改advertised.listeners IP 步骤五：验证接口连通性
RequestTimeoutException; import com.huaweicloud.sdk.core.exception.ServiceResponseException; import com.huaweicloud.sdk.kafka.v2.region.KafkaRegion;
消息引擎。取值填写为：kafka。 engine_version 是 String 消息引擎的版本。取值填写为： 1.1.0 2.3.0 2.7 3.x broker_num 是 Integer 代理个数。 storage_space 是 Integer 消息存储空间，单位GB。 Kafka实例规格为c6
2xlarge.2" }], "name": "cluster", "unavailable_zones": [] }] }], "Monthly": [{ "name": "kafka", "version": "XXX", "values": [{
说明 partition Integer 是 分区ID。 replicas Array of integer 是 副本期望所在的broker ID。其中Array首位为leader副本，所有分区需要有同样数量的副本，副本数不能大于总broker的数量。 请求示例 { "partitions":
实例管理 重置密码 重置Manager密码 重启Manager 修改实例跨VPC访问的内网IP 查询Kafka集群元数据信息 查询Kafka实例的协调器信息 修改Kafka的接入方式 查询topic的磁盘存储情况 关闭Kafka Manager 删除用户/客户端流控配置 查询用户/客户端流控配置
开通自动续费后，还可以手动续费该Kafka实例。手动续费后，自动续费仍然有效，在新的到期时间前的第7天开始扣款。 自动续费的到期前7日自动扣款属于系统默认配置，您也可以根据需要修改此扣款日，如到期前6日、到期前5日等等。 更多关于自动续费的规则介绍请参见自动续费规则说明。 前提条件 请确认包年/包月Kafka实例还未到期。
Topic维度下最多展示Top 20的数据。 Broker维度 按生产入流量从大到小的顺序对Broker进行排序，并以不同颜色显示Broker中不同Topic的生产入流量分布。将鼠标悬停在某个Broker柱形图上，会显示此Broker中所有Topic的生产入流量的具体数值。 单击右上角的选
Kafka Manager管理 Kafka Manager是开源的Kafka集群管理工具，您可以通过浏览器访问Kafka Manager。在Kafka Manager页面，您可以查看Kafka集群的监控、节点等信息。 支持区域： 全部 连接和查看Kafka Manager 重置Kafka
