检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
/config/ssl-user-config.properties 参数说明如下： connection-address：在Kafka控制台的“基本信息 > 连接信息”中，获取Kafka实例的连接地址。 consumer-group-name：消费组名称。
表1 实例参数 名称 代理数量 规格 是否开启SASL 磁盘类型 kafka-01 3 kafka.2u4g.cluster 是 超高I/O kafka-02 3 kafka.4u8g.cluster 是 超高I/O kafka-03 3 kafka.8u16g.cluster 是
请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 topic 否 String topic名称。 partition 是 Integer 分区编号，默认值为-1，若传入值为-1，则重置所有分区。
多副本的Topic需要在生产客户端配置重试机制，方法如下： 生产客户端为Kafka开源客户端时，检查是否配置retries参数，建议此参数值设置为3~5。 生产客户端为Flink客户端时，检查是否配置重启策略，配置重启策略可以参考如下代码。
请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 task_name 否 String SmartConnect任务名称。 start_later 否 Boolean 是否稍后再启动任务。
图5 创建通知策略 表1 通知策略参数说明 参数名称 说明 语言 选择通知策略的语言。 名称 设置通知策略的名称。 告警级别 选择“重要”。 通知类型 选择“触发”，即触发告警时发送通知。 接收对象 选择“主题订阅”，单击“创建主题”，进入消息通知服务中，创建主题和添加订阅。
变更实例规格 × √ 重置Kafka密码 × √ 查看磁盘使用量 × √ 修改分区平衡 × √ 设置Topic权限 × √ 用户管理 × √ 查看重平衡日志 × √ Smart Connect × √ 流控管理 × √ 修改配置参数 × √
可以在生产者端配置“compression.type”参数来启用指定类型的压缩算法。
在“新建工单”页面，根据您的需求，填写相关参数。 其中，“问题描述”项请填写需要调整的内容和申请原因。 填写完毕后，勾选协议并单击“提交”。
表1 重平衡参数说明 参数名称 说明 level 重平衡日志的等级，只有“INFO”一种等级。 timestamp Rebalance时间。 leaderId 消费者Leader ID。 generationId 消费组Generation ID。
/config/ssl-user-config.properties 参数说明如下： connection-address：在Kafka控制台的“基本信息 > 连接信息”中，获取Kafka实例的连接地址。 group-name：消费组名称。
请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 name 否 String 实例名称。 由英文字符开头，只能由英文字母、数字、中划线、下划线组成，长度为4~64的字符。 description 否 String 实例的描述信息。 长度不超过1024的字符串。
“allow.everyone.if.no.acl.found”在配置参数中修改。
设置自动平衡参数。 表1 自动平衡参数说明 参数名称 说明 Broker名称 勾选目标Broker的名称，Topic分区的副本即将迁移至目标Broker上。 副本数 输入Topic需要自动平衡的副本数，副本数须小于等于Broker的数量。
表1 自动平衡参数说明 参数名称 说明 Broker名称 勾选目标Broker的名称，Topic分区的副本即将迁移至目标Broker上。 副本数 输入Topic的副本数，副本数须小于等于Broker的数量。 带宽限制 输入带宽大小，默认值为“-1”，表示不限制带宽。
kafka安全协议、SASL PLAIN机制、用户名和密码的参数解释如下： 表3 密文接入参数说明 参数名称 参数值 说明 kafka安全协议 SASL_SSL 采用SASL方式进行认证，数据通过SSL证书进行加密传输，安全性更高。
其中涉及SASL认证配置，如果Kafka实例没有开启密文接入，使用的是不加密连接，请注释相关代码；如果Kafka实例开启了密文接入，则必须使用加密方式连接，请设置相关参数。
多副本的Topic需要在生产客户端配置重试机制，方法如下： 生产客户端为Kafka开源客户端时，检查是否配置retries参数，建议此参数值设置为3~5。 生产客户端为Flink客户端时，检查是否配置重启策略，配置重启策略可以参考如下代码。
available_zones：创建节点到指定的AZ ID，该参数不能为空数组或者数组的值为空，请参考查询可用区信息获取。 product_id：产品标识。请参考查询产品规格列表获取。 storage_spec_code：存储IO规格。具体取值范围，请参考创建实例。
图2 开启SSL双向认证 表1 开启SSL双向认证参数说明 参数名称 说明 Key密码 输入server.keystore.jks的密码 Keystore密码 输入server.keystore.jks的密码 Keystore文件 导入“server.keystore.jks”证书
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
