检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
果同时存在Allow和Deny，则遵循Deny优先原则。 如果您给用户授予DMS FullAccess的系统策略，但不希望用户拥有DMS FullAccess中定义的删除实例权限，您可以创建一条拒绝删除实例的自定义策略，然后同时将DMS FullAccess和拒绝策略授予用户，根据Deny优先原则，则用户可以对DMS
instance_id 是 String 实例ID。 topic 是 String Topic名称。 请求参数 无 响应参数 状态码：200 表2 响应Body参数 参数 参数类型 描述 topic String topic名称。 partitions Array of partitions objects
String topic名称。 policies 是 Array of AccessPolicyEntity objects 权限列表。 表4 AccessPolicyEntity 参数 是否必选 参数类型 描述 user_name 否 String 用户名称。 设置用户权限时，为必选参数。
0/OS-USER/users 请求消息头 附加请求头字段，如指定的URI和HTTP方法所要求的字段。例如定义消息体类型的请求头“Content-Type”，请求鉴权信息等。 详细的公共请求消息头字段请参见表2。 表2 公共请求消息头 名称 描述 是否必选 示例 Host 请求的服务器信息，从服务
实例。 表3 Hourly 参数 参数类型 描述 name String 消息引擎的名称，该字段显示为kafka。 version String 消息引擎的版本，当前支持1.1.0、2.3.0和2.7。 values Array of values objects 产品规格列表。
下： 登录Kafka Manager。 选择“Topic > List”，进入Topic列表页面。 单击待修改分区Leader的Topic名称（以topic-test为例介绍），进入Topic详情页面。 单击“Manual Partition Assignments”，进入修改分区Leader页面。
参数类型 描述 user_name 否 String 用户名称。 创建用户时，为必选参数。 user_desc 否 String 用户描述。 user_passwd 否 String 用户密码。 创建用户时，为必选参数。 密码不能和用户名相同。 复杂度要求： 输入长度为8到32位的字符串。
afka时需要填写，instance_id和bootstrap_servers仅需要填写其中一个） bootstrap_servers 否 String 对端Kafka实例地址。（仅源端类型为Kafka时需要填写，instance_id和bootstrap_servers仅需要填写其中一个）
请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 instance_id 是 String 需要关闭connector的实例id，和请求路径上的一致。 url 否 String 提交关闭connector订单后前端跳转的页面 响应参数 状态码： 200 表3 响应Body参数
参数类型 描述 name 否 String 配置名称 value 否 String 配置值 响应参数 无 请求示例 修改Topic参数，topic-1284340884的老化时间修改为72小时，分区数修改为6，新增分区分布在broker-1和broker-2上，不同步复制，不同步落盘，
fka实例列表页面。 单击Kafka实例的名称，进入实例详情页面。 在“配置参数”页面，在待修改参数所在行，单击“编辑”，修改配置参数。 1.1.0版本实例的参数说明如表1和表2所示，2.3.0/2.7/3.x版本实例的参数说明如表3和表4所示。 表1 动态参数说明（1.1.0版本）
instance_id 是 String 实例ID。 group 是 String 消费组名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 topic 否 String topic名称。 partition 是 Integer 分区编号，默认值为-1，若传入值为-1，则重置所有分区。
Kafka实例支持多副本存储，存储空间用于存储消息（包括副本中的消息）、日志和元数据。您在创建Kafka实例，选择初始存储空间时，建议根据业务消息体积预估、副本数量以及预留磁盘大小选择合适的存储空间。每个Kafka代理会预留33GB的磁盘空间，用于存储日志和元数据。 例如：业务消息体积预估100GB，副本数
String 实例ID。 group 是 String 消费组名称。 表2 Query参数 参数 是否必选 参数类型 描述 topic 否 String topic名称。 partition 否 String 分区名称。 offset 否 String 偏移值。 limit 否 String
String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 group_name 是 String 消费组名称 group_desc 否 String 消费组描述 响应参数 状态码：200 表3 响应Body参数 参数 参数类型 描述 - String
维护时间窗开始时间，格式为HH:mm:ss。 维护时间窗开始和结束时间必须为指定的时间段，可参考查询维护时间窗时间段获取。 开始时间必须为22:00:00、02:00:00、06:00:00、10:00:00、14:00:00和18:00:00。 该参数不能单独为空，若该值为空，则结
topic：按topic名称排序。 partition：按分区数排序。 messages：按消息数量排序，默认方式。 sort_dir 否 String 排序方式。 asc：升序。 desc：降序，默认方式。 topic 否 String topic名称。 请求参数 无 响应参数
String 节点名称。 表5 queues 参数 参数类型 描述 name String topic名称。 partitions Array of partitions objects 分区列表。 表6 partitions 参数 参数类型 描述 name String 分区名称。 表7
} } } 消费者线程管理代码示例： 示例仅提供简单的设计思路，开发者可结合实际场景优化线程休眠和唤醒机制。 topicName配置为Topic名称。 package com.huawei.dms.kafka; import java.util.HashMap;
instance_id 是 String 实例ID。 group 是 String 消费组名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 topic 否 String topic名称。 partition 是 Integer 分区编号，默认值为-1，若传入值为-1，则重置所有分区。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
