-
计费样例 - 分布式消息服务Kafka版
于2023/03/20 9:00:00升配为kafka.4u8g.cluster*3。
-
生产消息失败 - 分布式消息服务Kafka版
生产消息失败 问题现象 系统提示“Disk error when trying to access log file on the disk”错误。 根因描述 节点磁盘使用率超高导致生产消息失败。 问题解决措施 扩容实例的磁盘空间,具体操作请参考变更实例规格。
-
认证鉴权 - 分布式消息服务Kafka版
AK/SK认证:通过AK(Access Key ID)/SK(Secret Access Key)加密调用请求。推荐使用AK/SK认证,其安全性比Token认证要高。 Token认证 Token的有效期为24小时,需要使用一个Token鉴权时,可以先缓存起来,避免频繁调用。
-
重启Manager - 分布式消息服务Kafka版
{ "result" : "success", "instance_id" : "605cd78c-92dc-4335-8bae-43677f31fd6c" } SDK代码示例 SDK代码示例如下。
-
在Kafka Manager上支持修改Topic的哪些属性? - 分布式消息服务Kafka版
具体修改方法如下: 登录Kafka Manager。 单击“kafka_cluster”,进入“Summary”界面。 单击“Topic > List”,进入“Topics”界面。 单击需要修改属性的Topic名称,进入Topic详情界面。
-
查询Kafka集群元数据信息 - 分布式消息服务Kafka版
请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 cluster cluster object 集群基本信息。 表3 cluster 参数 参数类型 描述 controller String 控制器ID。
-
查询Kafka集群元数据信息 - 分布式消息服务Kafka版
请求消息 请求参数 无 请求示例 无 响应消息 响应参数 表2 响应参数说明 参数 类型 说明 cluster Object of cluster 集群基本信息。参数请查看表3。 表3 cluster参数说明 参数 类型 说明 controller String 控制器ID。
-
产品规格 - 分布式消息服务Kafka版
实例规格以实例提供的ECS规格分类,具体如下: 集群版实例 kafka.2u4g.cluster.small kafka.2u4g.cluster kafka.4u8g.cluster kafka.8u16g.cluster kafka.12u24g.cluster kafka.16u32g.cluster
-
Kafka Manager概述 - 分布式消息服务Kafka版
图中①区域表示功能导航栏 Cluster: 集群,统计集群列表和集群详情。 Brokers: 代理,统计当前集群中各代理的状态信息。 Topic: 队列,统计当前集群中的kafka队列。
-
查询用户权限 - 分布式消息服务Kafka版
{ "name" : "topic-test", "policies" : [ { "owner" : false, "user_name" : "xxxa", "access_policy" : "pub" }, { "owner" :
-
设置用户权限 - 分布式消息服务Kafka版
= model.GetAccessPolicyEntityAccessPolicyEnum().ALL var listPoliciesTopics = []model.AccessPolicyEntity{ { UserName: &userNamePolicies
-
消费者消费Topic失败,提示没有权限? - 分布式消息服务Kafka版
此时A对Topic 3和Topic 6是没有授权的,因此会出现“Not authorized to access topics”的报错。
-
计费项 - 分布式消息服务Kafka版
计费示例 以包年/包月计费模式为例,假设您于2023/03/08 15:50:04在“华北-北京四”区域购买了一个包年/包月Kafka实例(规格:kafka.2u4g.cluster*3,总存储空间:超高I/O 300GB),计费资源包括实例费用(代理规格和代理数量),以及存储空间费用
-
查看Kafka审计日志 - 分布式消息服务Kafka版
重置消费组偏移量失败 kafka Kafka_reset_consumer_offsetFailure 创建用户成功 kafka createUserSuccess 创建用户失败 kafka createUserFailure 删除用户成功 kafka deleteUserSuccess
-
变更Kafka实例规格 - 分布式消息服务Kafka版
例如:kafka.4u8g.cluster*3的实例,已创建800个分区,您想把此实例的规格缩容为kafka.2u4g.cluster*3,kafka.2u4g.cluster*3规格的实例分区数上限为750,此时无法缩容。
-
创建用户并授权使用DMS for Kafka - 分布式消息服务Kafka版
在“服务列表”中选择云硬盘(假设当前策略仅包含DMS ReadOnlyAccess),若提示权限不足,表示“DMS ReadOnlyAccess”已生效。
-
重置Manager密码 - 分布式消息服务Kafka版
重置Manager密码 功能介绍 重置Manager密码。 调用方法 请参见如何调用API。
-
管理Kafka Manager - 分布式消息服务Kafka版
管理Kafka Manager Kafka Manager概述 重置Kafka Manager密码 重启Kafka Manager 关闭Kafka Manager 父主题: 管理实例
-
设置Kafka Topic权限 - 分布式消息服务Kafka版
设置Kafka Topic权限 分布式消息服务Kafka版支持对Topic进行ACL(Access Control List)权限管理,您可以在Topic中为不同的用户设置不同的权限,以达到用户之间的权限隔离。
-
Kafka是否支持Kerberos认证,如何开启认证? - 分布式消息服务Kafka版
Kafka是否支持Kerberos认证,如何开启认证? Kafka支持SASL客户端认证、调用接口支持Token和AK/SK两种认证,Kerberos认证目前不支持。 如果使用SASL认证方式,则在开源客户端基础上使用分布式消息服务Kafka版提供的证书文件。