检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
client.ShowPartitionMessage(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.BatchDeleteMessageDiagnosisReports(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.UpdateInstanceCrossVpcIp(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.CreateInstanceUser(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.ModifyInstanceConfigs(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
解决方法/排查思路 场景一：未能及时发送心跳请求 排查思路：如果是Java语言客户端，建议排查GC日志是否存在长时间FullGC的情况。该场景可能会导致心跳线程阻塞，服务端检查心跳失败，进入Rebalance状态。
= client.SendKafkaMessage(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.DeleteKafkaUserClientQuotaTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.ShowInstanceMessages(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.BatchCreateOrDeleteKafkaTag(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.UpdateTopicAccessPolicy(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.UpdateTopicReplica(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.CreateKafkaUserClientQuotaTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.UpdateKafkaUserClientQuotaTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
图1 复制数据规则配置 （可选）在页面右下角单击“开始检测”，测试两端Kafka实例的连通性。 显示“连通性检测成功”时，表示两端Kafka实例可以正常连接。 单击“立即创建”，跳转到Smart Connect任务列表页面，页面右上角显示“创建xxx任务成功”。
client.CreateInstanceTopic(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
使用Python语言连接实例时，需要用CRT格式的证书。 sasl_mechanism：SASL认证机制。在Kafka实例控制台的基本信息页面中获取。如果SCRAM-SHA-512和PLAIN都开启了，根据实际情况选择其中任意一种配置连接。
client.UpdateInstanceTopic(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
最新版本SDK在各语言对应界面下载，请参见SDK概述。
client.ListEngineProducts(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
