检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
es/{instance_id}/management/coordinators 响应示例 状态码：200 查询Kafka实例的协调器信息成功。 { "coordinators" : [ { "group_id" : "XXXX", "id" : 2,
nstances/{instance_id}/management/cluster 响应示例 状态码：200 查询Kafka集群元数据信息成功。 { "cluster" : { "controller" : "2", "brokers" : [ {
{project_id}/instances/{instance_id}/topics/diskusage 响应示例 状态码：200 查询成功。 { "broker_list" : [ { "broker_name" : "broker-0", "data_disk_size"
Kafka实例的连通性。 显示“连通性检测成功”时，表示两端Kafka实例可以正常连接。 单击“立即创建”，跳转到Smart Connect任务列表页面，页面右上角显示“创建xxx任务成功”。 Kafka数据复制的Smart Connect任务创建成功后，Kafka会自动创建以下Topic。
如何选择Kafka实例存储容量阈值策略？ 支持以下两种策略： 生产受限策略 该策略场景下一旦磁盘使用达到容量阈值95%，会导致后续生产失败，但保留了当前磁盘中的数据，直至数据自然老化（Kafka原有的老化机制，数据默认保留3天）。该场景适用于对数据不能丢的业务场景，但是会导致生产业务失败。
https://{endpoint}/v2/{project_id}/instances/{instance_id}/ces-hierarchy 响应示例 状态码：200 查询成功。 { "dimensions" : [ { "name" : "kafka_instance_id", "metrics"
/{project_id}/instances/{instance_id}/tasks/{task_id} 响应示例 状态码：200 查询成功。 { "task_count" : "1", "tasks" : [ { "id" : "8abfa7b272adc5b40172b73130065ae7"
{instance_id}/message-diagnosis/{report_id} 响应示例 状态码：200 查询消息积压诊断报告详情成功 { "abnormal_item_num" : 2, "failed_item_num" : 2, "normal_item_num"
Key。 消息进行转储时，不支持以Key作为文件名。 单击“立即创建”，跳转到Smart Connect任务列表页面，页面右上角显示“创建xxx任务成功”。 父主题： 使用Smart Connect迁移数据
product_id的别名。 请求示例 GET https://{endpoint}/v2/kafka/products 响应示例 状态码：200 查询产品规格列表成功。 { "engine" : "kafka", "versions" : [ "1.1.0", "2.3.0" ], "products"
_id}/instances/{instance_id}/topics?offset=0&limit=10 响应示例 状态码：200 查询成功。 { "total" : 1, "size" : 0, "topics" : [ { "policiesOnly" :
ance_id}/management/topics/{topic}/messages 响应示例 状态码：200 查询分区指定时间段的消息成功。 { "messages" : [ { "topic" : "mytest", "partition" : 0,
https://{endpoint}/v2/{project_id}/instances/{instance_id}/configs 响应示例 状态码：200 获取实例配置成功。 { "kafka_configs" : [ { "name" : "min.insync.replicas", "valid_values"
"throttle" : 10000000, "time_estimate" : false } 响应示例 状态码：200 提交重平衡任务成功（若为预估时间任务则返回预估时间）。 { "job_id" : "8a2c259182ab0e9d0182ab1882560009",
[ "0e35a9f4-e75d-4fd6-b230-280860f666f7" ] } 响应示例 状态码：200 批量删除消息积压诊断报告成功 { "results" : [ { "result" : "true", "id" : "0e35a9f4-e75d
https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags 响应示例 状态码：200 查询实例标签成功。 { "tags" : [ { "key" : "key1", "value" : "value1" }, {
久前创建的Kafka实例在详情页如果未显示“开启的SASL认证机制”，默认使用PLAIN机制。 security_protocol：Kafka的安全协议。在Kafka实例控制台的基本信息页面中获取。很久前创建的Kafka实例在详情页如果未显示“启用的安全协议”，默认使用SASL_SSL协议。
d}/diagnosis-check?group=group-1&topic=topic-1 响应示例 状态码：200 消息积压诊断预检查成功 [ { "name" : "RAM", "success" : false, "reason" : "1,2" }, {
}/message-diagnosis-tasks?offset=1&limit=10 响应示例 状态码：200 查询消息积压诊断报告列表成功 { "report_list" : [ { "report_id" : "89b202d5-1f34-4a89-af9d-698496d0b7b1"
请求示例 GET https://{endpoint}/v2/instances/maintain-windows 响应示例 状态码：200 查询成功。 { "maintain_windows" : [ { "default" : false, "seq" : 1,
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
