检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
任务数 数据复制的任务数。默认值为2，建议保持默认值。 如果“同步方式”为“双向”，实际任务数=设置的任务数*2。 重命名Topic 在目标Topic名称前添加源端Kafka实例的别名，形成目标Topic新的名称。
partition：按分区数排序。 messages：按消息数量排序，默认方式。 sort_dir 否 String 排序方式。 asc：升序。 desc：降序，默认方式。 topic 否 String topic名称。
limit Integer 否 单页返回消息数，默认值为10。 offset Integer 否 查询的页码，默认值为1。 请求消息 请求参数 无 请求示例 无。 响应消息 响应参数 参数说明见表2。
表1 关键指标列表 维度 关键指标 消费组 消息堆积数 消费组已消费消息数 主题 队列消息总数 生产流量 消费流量 节点 CPU使用率 网络带宽利用率 磁盘读流量 磁盘写流量 图1 关键指标TopN排序 父主题： 查看监控指标与配置告警
lag Long 剩余可消费消息数，即消息堆积数。 topic String topic名称。 message_current_offset Long 当前消费进度。 message_log_end_offset Long 最大消息位置（LEO）。
num-records：总共需要发送的消息数。 record-size：每条消息的大小。 throughput：每秒发送的消息数。 测试步骤 测试场景一：批处理大小 登录客户端服务器，进入“kafka_2.12-2.7.2/bin”目录下，执行以下脚本。
lag Long 该副本当前落后hw的消息数。
查询实例标签 查询项目标签 诊断管理 包括： 消息积压诊断预检查 创建消息积压诊断任务 查询消息积压诊断报告列表 批量删除消息积压诊断报告 查询诊断报告详情 其他接口 包括： 查询维护时间窗时间段 查询可用区信息 查询产品规格列表 查询实例在CES的监控层级关系 查询Kafka产品规格核数
图1 选择需要创建告警通知的消费组 在“消息堆积数（消费组可消费消息数）”图表上单击，创建告警规则。 图2 消息堆积数图表 在“创建告警规则”页面，设置告警名称。告警名称需要符合命名规则：只能由中文、英文字母、数字、下划线、中划线组成。
例如扩容前实例的代理数为3，每个代理的磁盘大小为200GB，扩容后实例的代理数为10，此时代理的磁盘大小依旧为200GB，但是总磁盘大小为2000GB。 新创建的Topic才会分布在新代理上，原有Topic还分布在原有代理上，造成分区分布不均匀。
分区数 如果分区数与消费者数一致，分区数越大消费的并发度越大。 输入“3”。 副本数 Kafka会自动在每个副本上备份数据，当其中一个Broker故障时数据依然是可用的，副本数越大可靠性越高。 输入“3”。
单个代理最大分区数*代理数量=实例分区数上限。当所有Topic的总分区数大于实例分区数上限时，创建Topic失败。 代理数量 选择代理数量。 单个代理存储空间 选择存储Kafka数据的磁盘类型和磁盘大小。Kafka实例创建后，磁盘类型不支持修改。
其他建议 连接数限制：3000 消息大小：不能超过10MB 使用SASL_SSL协议访问Kafka：确保DNS具有反向解析能力，或者在hosts文件配置Kafka所有节点IP和主机名映射，避免Kafka client做反向解析，阻塞连接建立。
total_number Integer Smart Connector任务数。 max_tasks Integer Smart Connector最大任务数。 quota_tasks Integer Smart Connector任务配额。
Kafka实例创建Topic的分区数必须在1-200范围内。
partition 否 Integer topic分区数，设置消费的并发数。取值范围：1-200。 sync_replication 否 Boolean 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效，默认关闭。
支持区域： 全部 创建Topic 修改Topic老化时间 修改Topic分区数 变更实例规格 Kafka实例创建成功后，您可以根据业务需要，扩容基准带宽、代理个数、存储空间、代理规格，或者缩容代理规格。 扩容存储空间有次数限制，只能扩容20次。
分区平衡任务启动后，无法修改Topic的分区数。 分区平衡任务启动后，无法手动停止任务，需要等到任务完成。 已设置了一个定时分区平衡任务，在此任务未执行前，无法对本实例内的任何Topic执行其他分区平衡任务。
您可以通过修改Kafka实例配置参数来修改单IP的连接数，即修改max.connections.per.ip参数值。 前提条件 已打通客户端和Kafka实例之间的网络，具体网络要求请参考连接Kafka网络要求。 已配置正确的安全组。
partition_num String Kafka实例的最大Topic数。 product_id String 产品ID。 spec_code String 规格ID。 io Array IO信息。具体参数，请参见表6。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
