检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
partitions Array of integers 诊断异常受影响的分区列表 failed_partitions Array of integers 诊断失败的分区列表 broker_ids Array of integers 诊断异常受影响的broker列表 表5 KafkaMessag
response, err := client.PauseConnectorTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
cluster.small 2000 kafka.2u4g.single.small 2000 kafka.2u4g.cluster 2000 kafka.2u4g.single 2000 kafka.4u8g.cluster 4000 kafka.8u16g.cluster 4000
response, err := client.UpdateSinkTaskQuota(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
response, err := client.CreateConnector(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。
) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。
参数说明 参数 类型 说明 total Integer topic总数。 size Integer 分页查询的大小。 remain_partitions Integer 剩余分区数。 max_partitions Integer 分区总数。 topics Array Topic列表。
response, err := client.DeleteConnector(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
response, err := client.RestartConnectorTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
response, err := client.ResumeConnectorTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
RequestTimeoutException; import com.huaweicloud.sdk.core.exception.ServiceResponseException; import com.huaweicloud.sdk.kafka.v2.region.KafkaRegion;
) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。
的Body体格式如下所示。 { "error_msg": "The format of message is error", "error_code": "AS.0001" } 其中，error_code表示错误码，error_msg表示错误描述信息。 父主题： 如何调用API
String 实例id topic 是 String 主题 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 偏移量，表示查询该偏移量后面的记录 limit 否 Integer 查询返回记录的数量限制 请求参数 无 响应参数 状态码：200 表3
RequestTimeoutException; import com.huaweicloud.sdk.core.exception.ServiceResponseException; import com.huaweicloud.sdk.kafka.v2.region.KafkaRegion;
RequestTimeoutException; import com.huaweicloud.sdk.core.exception.ServiceResponseException; import com.huaweicloud.sdk.kafka.v2.region.KafkaRegion;
响应Body参数 参数 参数类型 描述 error_code String 错误码。 error_msg String 错误描述。 状态码：403 表7 响应Body参数 参数 参数类型 描述 error_code String 错误码。 error_msg String 错误描述。
RequestTimeoutException; import com.huaweicloud.sdk.core.exception.ServiceResponseException; import com.huaweicloud.sdk.kafka.v2.region.KafkaRegion;
未开启SASL： ./kafka-consumer-groups.sh --bootstrap-server {connection-address} --describe --group {group-name} 已开启SASL： ./kafka-consumer-groups.sh --bootstrap-server
