检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
生产或消费消息时，报Topic {{topic_name}} not present in metadata after 60000 ms错误 问题现象 多可用区的Kafka实例，在某个可用区故障后，Kafka客户端在生产或消费消息时，可能会报Topic {{topic_name}} not present
cs/{topic_name}/accesspolicy 响应示例 状态码： 200 查询成功。 { "name" : "topic-test", "policies" : [ { "owner" : false, "user_name" : "xxxa"
instance.kafka.cluster.c3.mini：Kafka实例的基准带宽为100MB。 dms.instance.kafka.cluster.c3.small.2：Kafka实例的基准带宽为300MB。 dms.instance.kafka.cluster.c3.middle
认证鉴权 调用接口有如下两种认证方式，您可以选择其中一种进行认证鉴权。 AK/SK认证：通过AK（Access Key ID）/SK（Secret Access Key）加密调用请求。推荐使用AK/SK认证，其安全性比Token认证要高。 Token认证：通过Token认证调用请求。
new.pod.port,feature.physerver.kafka.topic.modify,feature.physerver.kafka.topic.accesspolicy,message_trace_enable,features.pod.token.access,feature
new.pod.port,feature.physerver.kafka.topic.modify,feature.physerver.kafka.topic.accesspolicy,message_trace_enable,features.pod.token.access,feature
Array of AccessPolicyTopicEntity objects topic列表。 表3 AccessPolicyTopicEntity 参数 是否必选 参数类型 描述 name 是 String topic名称。 policies 是 Array of AccessPolicyEntity
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 name 否 String 实例名称。 由英文字符开头，只能由英文字母、数字、中划线、下划线组成，长度为4~64的字符。 description
生产消息失败 问题现象 系统提示“Disk error when trying to access log file on the disk”错误。 根因描述 节点磁盘使用率超高导致生产消息失败。 问题解决措施 扩容实例的磁盘空间，具体操作请参考变更Kafka实例规格。
URI GET /v1.0/{project_id}/instance/{instance_id}/manage/topic/{topic_name}/partition/{partition}/offset/{offset}/message 参数说明见表1。 表1 参数说明 参数 类型
_id}/users/{user_name} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 user_name 是 String 用户名称。 请求参数
"effdcbcxxx6b42f56533" ], "product_id": "c6.2u4g.cluster", "storage_spec_code": "dms.physical.storage.high.v2" } name：实例名称，由您自行定义。 engine：消息引擎，设置kafka。 e
request.user_name = "{user_name}" request.body = UpdateUserReq( user_desc="用户描述", user_name="用户名",
[{ "name": "aaaa", "partitions": [{ "name": "0" }] }, { "name": "mytest", "partitions": [{ "name": "0" }, { "name": "1"
e_id}/users/{user_name} dms:instance:get √ √ 查询用户权限 GET /v1/{project_id}/instances/{instance_id}/topics/{topic_name}/accesspolicy dms:instance:get
{ "name" : "RAM", "success" : false, "reason" : "1,2" }, { "name" : "CPU", "success" : false, "reason" : "1,2" }, { "name" : "SUBSCRIPTION"
设置Kafka Topic权限 Kafka实例开启密文接入后，支持对Topic进行ACL（Access Control List）权限管理，您可以在Topic中为不同的用户设置不同的生产消费消息的权限，以达到用户之间的权限隔离。 本章节主要介绍Kafka实例开启密文接入后，如何对Topic进行用户授权。
kafka.cluster.c3.mini：Kafka实例的基准带宽为100MByte/秒。 dms.instance.kafka.cluster.c3.small.2：Kafka实例的基准带宽为300MByte/秒。 dms.instance.kafka.cluster.c3.middle
"name" : "broker-2" } ], "queues" : [ { "name" : "aaaa", "partitions" : [ { "name" : "0" } ] }, { "name" : "mytest"
法性校验，同时提供登录保护和登录验证策略加固身份认证安全。 DMS for Kafka基于统一身份认证服务（Identity and Access Management，简称IAM），支持三种身份认证方式：用户名密码、访问密钥、临时访问密钥。同时还提供登录保护及登录验证策略。 访问控制
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
