检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
权限仅包含DMS ReadOnlyAccess），表示“DMS ReadOnlyAccess”已生效。 在“服务列表”中选择云硬盘（假设当前策略仅包含DMS ReadOnlyAccess），若提示权限不足，表示“DMS ReadOnlyAccess”已生效。 在“服务列表”中选择
费者授权不同的Topic访问权限，某一消费者消费其中一个Topic时，提示消费失败，报错信息如下：Not authorized to access topics。 问题原因：消费组的leader在进行分区分配时，不会考虑某一个消费者的授权和订阅信息，只会根据消费组整体的订阅情况进
"name" : "broker-2" } ], "queues" : [ { "name" : "aaaa", "partitions" : [ { "name" : "0" } ] }, { "name" : "mytest"
配置Kafka ACL用户 Kafka实例开启密文接入后，支持对Topic进行ACL（Access Control List）权限管理，您可以在Topic中为不同的用户设置不同的生产消费消息的权限，以达到用户之间的权限隔离。 本章节主要介绍Kafka实例开启密文接入后，如何创建用
DMS FullAccess DMS UserAccess DMS ReadOnlyAccess DMS VPCAccess DMS KMSAccess DMS ELBAccess DMS VPCEndpointAccess DMSAgencyCheckAccessPolicy 创建实例
kafka.cluster.c3.mini：Kafka实例的基准带宽为100MByte/秒。 dms.instance.kafka.cluster.c3.small.2：Kafka实例的基准带宽为300MByte/秒。 dms.instance.kafka.cluster.c3.middle
destination_file_type 是 String 转储文件格式。当前只支持text。 access_key 是 String 访问密钥AK。 secret_key 是 String 访问密钥SK。 obs_bucket_name 是 String 存储该通道数据的OBS桶名称。 obs_path 否
--group ${consumer-group-name} 参数说明如下： connection-address：在Kafka控制台的“基本信息 > 连接信息”中，获取Kafka实例的连接地址。 consumer-group-name：消费组名称。 示例如下： [root@ecs-kafka
部分内容。 { "user": { "id": "c131886aec...", "name": "IAMUser", "description": "IAM User Description",
Kafka实例规格为c6.2u4g.cluster时，存储空间取值范围300GB ~ 300000GB。 Kafka实例规格为c6.4u8g.cluster时，存储空间取值范围300GB ~ 600000GB。 Kafka实例规格为c6.8u16g.cluster时，存储空间取值范围300GB
填写） current_cluster_name 否 String 当前Kafka实例别名。（仅源端类型为Kafka时需要填写） cluster_name 否 String 对端Kafka实例别名。（仅源端类型为Kafka时需要填写） user_name 否 String 对端K
事件名称 创建DMS实例订单成功 kafka createDMSInstanceOrderSuccess 创建DMS实例任务执行成功 kafka createDMSInstanceTaskSuccess 创建DMS实例订单失败 kafka createDMSInstanceOrderFailure
200 修改实例跨VPC访问的内网IP成功。 { "success" : true, "results" : [ { "advertised_ip" : "192.168.197.36", "success" : true, "ip" : "192.168
age" : "1", "status" : "Success get info", "topic_list" : [ { "size" : "12K", "topic_name" : "topic-test", "topic_partition"
/restart-kafka-manager 响应示例 状态码： 200 重启Manager成功。 { "result" : "success", "instance_id" : "605cd78c-92dc-4335-8bae-43677f31fd6c" } SDK代码示例
请求参数product_id非法。 请检查参数product_id 400 DMS.00400010 Invalid instance name. The name must be 4 to 64 characters long. Only letters, digits, underscores
connector-order { "instance_id" : "20c6b355-5d95-45ef-b476-e38bcccce0d7", "url" : "https://console.xxx.xxx.com/dms/?engine=all®ion=x
tasks objects 任务列表。 表4 tasks 参数 参数类型 描述 id String 任务ID。 name String 任务名称。 user_name String 用户名。 user_id String 用户ID。 params String 任务参数。 status
tasks objects 任务列表。 表3 tasks 参数 参数类型 描述 id String 任务ID。 name String 任务名称。 user_name String 用户名。 user_id String 用户ID。 params String 任务参数。 status
/kafka/instances/{instance_id}/group { "group_name" : "test" } 响应示例 状态码： 200 创建成功。 success SDK代码示例 SDK代码示例如下。 Java Python Go 更多 创建一个消费组，消费组名为test。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
