检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
client.ListBackgroundTasks(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
可使用telnet方式，检测实例连接地址与端口。
查看Kafka生产消费示例代码 分布式消息服务Kafka版支持在控制台查看Java、Go和Python语言的生产消费消息示例代码，您可以参考示例代码快速完成Kafka客户端的集成，并进行消息的生产和消费。 查看Kafka生产消费示例代码 登录管理控制台。
表1 SDK列表 编程语言 Github地址 参考文档 Java huaweicloud-sdk-java-v3 Java SDK使用指导 Python huaweicloud-sdk-python-v3 Python SDK使用指导 Go huaweicloud-sdk-go-v3
client.ShowDiagnosisPreCheck(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
跨语言支持 支持多语言的客户端。 采用Scala和Java编写，支持多种语言的客户端。 支持多种语言的客户端。 流量控制 RocketMQ 5.x支持基于实例规格的流量控制。 支持client、user和Topic级别，通过主动设置可将流控作用于生产者或消费者。
AZ内实例容灾 同一个AZ内，Kafka实例通过副本冗余方式实现实例容灾，当检测到leader副本故障后，快速完成副本选主，保障Kafka实例持续提供服务。 数据容灾 通过支持数据多副本方式实现数据容灾。
超时时间越短，consumer的心跳探测越频繁，可以使故障检测更快，但会导致broker被抢占更多的资源。
使用Java语言连接实例时，需要用JKS格式的证书。使用Python语言连接实例时，需要用CRT格式的证书。
图5 创建通知策略 表1 通知策略参数说明 参数名称 说明 语言 选择通知策略的语言。 名称 设置通知策略的名称。 告警级别 选择“重要”。 通知类型 选择“触发”，即触发告警时发送通知。 接收对象 选择“主题订阅”，单击“创建主题”，进入消息通知服务中，创建主题和添加订阅。
client.CreateKafkaConsumerGroup(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.RestartConnectorTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.ListAvailableZones(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.ResetManagerPassword(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.ShowPartitionBeginningMessage(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.ShowPartitionEndMessage(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
Sarama Sarama采用原生Golang语言编写，对于异步以及高并发操作支持度较好。 问题较多，文档相对较少。 Sarama在处理大量消息时，会占用较多的内存资源，可能会对应用程序的性能造成一定的影响。 父主题： 连接问题
client.ShowTopicAccessPolicy(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.BatchDeleteInstanceTopic(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.CreateMessageDiagnosisTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
