检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
单击“Manual Partition Assignments”，进入修改分区Leader页面。 图1 Topic详情页面 图2 修改分区Leader页面 以修改分区2的Leader为例介绍（Replica 0即为分区Leader），如上图所示，分区2的Leader为2。 修改分区Leader，单击“Save
例如：“num.partitions”修改为“5”，自动创建的Topic参数值如表1所示。 表1 Topic参数值 参数名称 单机实例默认值 集群实例默认值 集群实例修改后的值 分区数 1 3 5 副本数 1 3 3 老化时间 72小时 72小时 72小时 同步复制 不开启 不开启 不开启
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
置。 表1 Producer参数 参数 默认值 推荐值 说明 acks 1 高可靠：all或者-1 高吞吐：1 收到Server端确认信号个数，表示producer需要收到多少个这样的确认信号，算消息发送成功。acks参数代表了数据备份的可用性。常用选项： acks=0：表示pr
单击右上角的“更多 > 转包周期”，跳转到“按需转包年/包月”页面。 选择Kafka实例的购买时长，判断是否勾选“自动续费”，确认预计到期时间和配置费用后单击“去支付”。 图1 按需转包年/包月 进入支付页面，选择支付方式，确认付款，支付订单后即可完成按需转包年/包月。 父主题：
描述 offset 否 Integer 偏移量，表示从此偏移量开始查询， offset大于等于0。 limit 否 Integer 当次查询返回的最大topic个数，默认值为10，取值范围为1~50。 sort_key 否 String 排序规则： topic：按topic名称排序。
描述 offset 否 Integer 偏移量，表示从此偏移量开始查询， offset大于等于0。 limit 否 Integer 当次查询返回的最大消费组id个数，默认值为10，取值范围为1~50。 group 否 String 消费组名过滤查询，过滤方式为字段包含过滤。 topic
ized完成的时间进行计算得到以下结果图。图中时间为UTC+0时间，对应北京时间需要加8小时。 图1 消费组rebalance图 从以上图中可以看出，消费组rebalance的性能在7月1号06:49（即北京时间7月1号14:49）以后存在明显劣化的情况，导致客户端异常。 根因描述
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
详细状态说明请参考实例状态说明。 include_failure 否 String 是否返回创建失败的实例数。 当参数值为“true”时，返回创建失败的实例数。参数值为“false”，不返回创建失败的实例数。 exact_match_name 否 String 是否按照实例名称进行精确匹配查询。
被分布式存储在分区中。 副本（Replica） 消息的备份存储。为了确保消息可靠，Kafka创建Topic时，每个分区会分别从代理中选择1个或多个，对消息进行冗余存储。 Topic的所有消息分布式存储在各个分区上，分区在每个副本存储一份全量数据，副本之间的消息数据保持同步，任何一个副本不可用，数据都不会丢失。
业务实际情况设定 连续触发次数：1 告警级别：重要 该指标用于统计消费组指定队列可以消费的消息个数。 出现该告警时，首先排查消费者代码逻辑是否有误，例如消费者出现了异常不再消费等。其次，可以考虑加快消息的消费，例如增加队列消费者，并确保分区数大于或等于消费者数。 配置Kafka告警规则
描述 offset 否 Integer 偏移量，表示从此偏移量开始查询， offset大于等于0。 limit 否 Integer 当次查询返回的最大消费组成员个数，默认值为10，取值范围为1~50。 host 否 String 消费者地址。 member_id 否 String 消费者ID。
消费者每次最多消费max.poll.records条消息，多数情况下客户端都会把一次消费到的数据处理完后才会开始下一次消费，如果单次消费的消息太多导致无法在max.poll.interval.ms时间内处理完或消息处理流程发生了异常（如需要写入后端数据库，后端数据库压力太大，慢SQL，时延增加等）导致消费时间增加，在max
修改Kafka实例创建Topic和新增Kafka实例指定Topic分区的分区数最大值。 2021-05-11 本次变更如下： 修改开启或关闭实例自动创建topic功能的返回状态码和返回描述。 2021-04-16 新增以下接口： 查询用户列表 创建用户 批量删除用户 重置用户密码 查询用户权限 设置用户权限
服务的Region；专属Region指只承载同一类业务或只面向特定租户提供业务服务的专用Region。 可用区（AZ，Availability Zone） 一个可用区是一个或多个物理数据中心的集合，有独立的风火水电，AZ内逻辑上再将计算、网络、存储等资源划分成多个集群。一个Reg
sks?offset=1&limit=10 响应示例 状态码：200 查询消息积压诊断报告列表成功 { "report_list" : [ { "report_id" : "89b202d5-1f34-4a89-af9d-698496d0b7b1", "status"
衡。 系统重新实现了分区分配策略，但策略逻辑有问题，会导致分区间的数据不均衡。 Kafka扩容了Broker节点，新增的节点没有分配分区，会导致节点间的数据不均衡。 业务使用过程中随着集群状态的变化，多少会发生一些Leader副本的切换或迁移，会导致个别Broker节点上的数据更多，从而导致节点间的数据不均衡。
请参考申请弹性公网IP。 购买完成后，返回开启公网页面。 单击“弹性IP地址”后的，然后在下拉框中选择和代理数量相同的弹性IP地址，单击。 您可以在实例的“后台任务管理”页面，查看当前任务的操作进度。任务状态为“成功”，表示操作成功。 图1 开启公网访问 开启公网访问后，需要设置
在“创建告警规则”页面，设置告警策略。 图4 设置告警策略 告警策略：连续1次原始值>=10000个时，触发重要告警，每天发送一次告警通知。 在“创建告警规则”页面，单击“创建通知策略”，进入“创建通知策略”页面。 设置通知策略，单击“确定”。 图5 创建通知策略 表1 通知策略参数说明 参数名称 说明 语言 选择通知策略的语言。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
