检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
生产消息失败 问题现象 系统提示“Disk error when trying to access log file on the disk”错误。 根因描述 节点磁盘使用率超高导致生产消息失败。 问题解决措施 扩容实例的磁盘空间，具体操作请参考变更Kafka实例规格。
在“服务列表”中选择云硬盘（假设当前策略仅包含DMS ReadOnlyAccess），若提示权限不足，表示“DMS ReadOnlyAccess”已生效。
此时A对Topic 3和Topic 6是没有授权的，因此会出现“Not authorized to access topics”的报错。
AK/SK认证：通过AK（Access Key ID）/SK（Secret Access Key）加密调用请求。推荐使用AK/SK认证，其安全性比Token认证要高。 Token认证：通过Token认证调用请求。
https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/delete-connector-order { "instance_id" : "20c6b355-5d95-45ef-b476-e38bcccce0d7
权限和授权项 如果您需要对您所拥有的Kafka实例进行精细的权限管理，您可以使用统一身份认证服务（Identity and Access Management，简称IAM），如果华为账号已经能满足您的要求，不需要创建独立的IAM用户，您可以跳过本章节，不影响您使用Kafka实例的其它功能
new AccessPolicyEntity() .withUserName("root") .withAccessPolicy(AccessPolicyEntity.AccessPolicyEnum.fromValue
result String 操作结果：success、failed。
"success" : false, "reason" : "1,2" }, { "name" : "SUBSCRIPTION", "success" : false, "reason" : "0,2" }, { "name" : "LAG", "success
try { ShowTopicAccessPolicyResponse response = client.showTopicAccessPolicy(request); System.out.println(response.toString
设置Kafka Topic权限 Kafka实例开启密文接入后，支持对Topic进行ACL（Access Control List）权限管理，您可以在Topic中为不同的用户设置不同的生产消费消息的权限，以达到用户之间的权限隔离。
配置Kafka ACL用户 Kafka实例开启密文接入后，支持对Topic进行ACL（Access Control List）权限管理，您可以在Topic中为不同的用户设置不同的生产消费消息的权限，以达到用户之间的权限隔离。
表2 常用操作与系统策略的关系 操作 DMS FullAccess DMS UserAccess DMS ReadOnlyAccess DMS VPCAccess DMS KMSAccess DMS ELBAccess DMS VPCEndpointAccess DMSAgencyCheckAccessPolicy
DMS for Kafka基于统一身份认证服务（Identity and Access Management，简称IAM），支持三种身份认证方式：用户名密码、访问密钥、临时访问密钥。同时还提供登录保护及登录验证策略。
message_trace_enable,features.pod.token.access,feature.physerver.kafka.pulbic.dynamic,feature.physerver.kafka.user.manager", "trace_enable
响应示例 { "topics" : [{ "id" : "haha", "success" : true }, { "id" : "aabb", "success" : true } ] } 状态码 操作成功的状态码如表
message_trace_enable,features.pod.token.access,feature.physerver.kafka.pulbic.dynamic,feature.physerver.kafka.user.manager", "trace_enable
", "rest_produce_failed", "rest_produce_latency", "rest_produce_msg_num", "rest_produce_flow", "rest_consume_success", "rest_consume_failed",
创建用户成功 kafka createUserSuccess 创建用户失败 kafka createUserFailure 删除用户成功 kafka deleteUserSuccess 删除用户失败 kafka deleteUserFailure 更新用户策略成功 kafka updateUserPoliciesTaskSuccess
{ "success" : true, "results" : [ { "advertised_ip" : "192.168.197.36", "success" : true, "ip" : "192.168.197.36" }, {
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
