检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
client.ListInstanceConsumerGroups(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.ListTopicProducers(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
client.ListBackgroundTasks(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的
SDK概述 本文介绍了分布式消息服务Kafka版提供的SDK语言版本，列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能，降低您使用SDK的难度，推荐使用。 SDK列表 在开始使用之前，请确保您安装的是最新版本的SDK。
跨语言支持 支持多语言的客户端。 采用Scala和Java编写，支持多种语言的客户端。 支持多种语言的客户端。 流量控制 RocketMQ 5.x支持基于实例规格的流量控制。 支持client、user和Topic级别，通过主动设置可将流控作用于生产者或消费者。
使用Java语言连接实例时，需要用JKS格式的证书。使用Python语言连接实例时，需要用CRT格式的证书。
Sarama Sarama采用原生Golang语言编写，对于异步以及高并发操作支持度较好。 问题较多，文档相对较少。 Sarama在处理大量消息时，会占用较多的内存资源，可能会对应用程序的性能造成一定的影响。 父主题： 连接问题
图5 创建通知策略 表1 通知策略参数说明 参数名称 说明 语言 选择通知策略的语言。 名称 设置通知策略的名称。 告警级别 选择“重要”。 通知类型 选择“触发”，即触发告警时发送通知。 接收对象 选择“主题订阅”，单击“创建主题”，进入消息通知服务中，创建主题和添加订阅。
解决方法/排查思路 场景一：未能及时发送心跳请求 排查思路：如果是Java语言客户端，建议排查GC日志是否存在长时间FullGC的情况。该场景可能会导致心跳线程阻塞，服务端检查心跳失败，进入Rebalance状态。
e9993fc787d94b6c886cbaa340f9c0f4 X-Auth-Token 用户Token。 用户Token也就是调用获取用户Token接口的响应值，该接口是唯一不需要认证的接口。
[root@ecs-test ~]# python3 consumer.py start consumer 如需停止消费使用Ctrl+C命令退出。
", "default_az" : true, "remain_time" : 9223372036854776000, "ipv6_enable" : false }, { "soldOut" : false, "id" : "9f1c5806706d4c1fb0eb72f0a9b18c77
最新版本SDK在各语言对应界面下载，请参见SDK概述。
在Windows服务器中无法登录Kafka Manager 问题现象 在Windows服务器的浏览器中输入Kafka Manager地址，无法登录Kafka Manager，报错信息如下图。 根因描述 Windows服务器和Kafka实例不在同一个VPC同一个子网内，或者安全组配置不正确
查询Kafka实例所有消费组对应的协调器信息 当前页面API为历史版本API，未来可能停止维护。请使用查询Kafka实例的协调器信息。 URI GET /v1.0/{project_id}/instances/{instance_id}/manage/coordinators 参数说明如下表所示
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.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) } } 更多编程语言的
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
