-
创建实例时为什么无法查看子网和安全组等信息? - 分布式消息服务Kafka版
创建实例时,如果无法查看虚拟私有云、子网、安全组、弹性IP,可能原因是该用户的用户组无Server Administrator和VPC Administrator权限。增加用户组权限的详细步骤,请参考修改用户组权限。 父主题: 实例问题
-
修改Kafka实例Topic分区的副本 - 分布式消息服务Kafka版
其中Array首位为leader副本,所有分区需要有同样数量的副本,副本数不能大于总broker的数量。 响应参数 无 请求示例 修改Topic分区的副本分布位置,分区1的副本分布在broker 1和broker 2,Leader副本在broker 1。
-
查询Kafka集群元数据信息 - 分布式消息服务Kafka版
表4 brokers 参数 参数类型 描述 host String 节点IP。 port Integer 端口号。 broker_id String 节点ID。 is_controller Boolean 是否为contoller节点。
-
查询topic的磁盘存储情况 - 分布式消息服务Kafka版
percentage Double 磁盘使用量的占比。
-
查询实例在CES的监控层级关系 - 分布式消息服务Kafka版
", "broker_bytes_in_rate", "broker_produce_mean", "broker_fetch_mean" ], "key_name" : [ "nodes" ], "dim_router" : [ "kafka_instance_id
-
修改Kafka实例Topic - 分布式消息服务Kafka版
new_partition_numbers 否 Integer 分区数。
-
批量删除用户 - 分布式消息服务Kafka版
{ Users: &listUsersbody, Action: &actionBatchDeleteInstanceUsersReq, } response, err := client.BatchDeleteInstanceUsers(request) if err
-
查询用户列表 - 分布式消息服务Kafka版
表3 ShowInstanceUsersEntity 参数 参数类型 描述 user_name String 用户名称。 由英文字符开头,只能由英文字母、数字、中划线、下划线组成,长度为4~64的字符。 user_desc String 用户描述。
-
Kafka客户端使用建议 - 分布式消息服务Kafka版
consumer需周期poll,维持和server的心跳,避免心跳超时,导致consumer频繁加入和退出,阻塞消费。 consumer拉取的消息本地缓存应有大小限制,避免OOM(Out of Memory)。
-
计费样例 - 分布式消息服务Kafka版
于2023/03/20 9:00:00升配为kafka.4u8g.cluster*3。
-
Kafka连接问题排查和解决 - 分布式消息服务Kafka版
检查consumer.properties和producer.properties文件中的ssl.truststore.password参数是否配置正确。
-
Kafka相关概念 - 分布式消息服务Kafka版
订阅消息最终目的在于处理消息内容,如日志集成场景中,监控告警平台(消费者)从主题订阅日志消息,识别出告警日志并发送告警消息/邮件。
-
与其他云服务的关系 - 分布式消息服务Kafka版
云监控(Cloud Eye) 云监控是一个开放性的监控平台,提供资源的实时监控、告警、通知等服务。 Kafka实例向CloudEye上报监控数据的更新周期为1分钟。 弹性公网IP(Elastic IP) 弹性公网IP提供独立的公网IP资源,包括公网IP地址与公网出口带宽服务。
-
生产消息失败 - 分布式消息服务Kafka版
生产消息失败 问题现象 系统提示“Disk error when trying to access log file on the disk”错误。 根因描述 节点磁盘使用率超高导致生产消息失败。 问题解决措施 扩容实例的磁盘空间,具体操作请参考变更实例规格。
-
查看Kafka审计日志 - 分布式消息服务Kafka版
创建用户成功 kafka createUserSuccess 创建用户失败 kafka createUserFailure 删除用户成功 kafka deleteUserSuccess 删除用户失败 kafka deleteUserFailure 更新用户策略成功 kafka updateUserPoliciesTaskSuccess
-
查询产品规格列表 - 分布式消息服务Kafka版
max_storage_per_node String 每个节点的最大存储。单位为GB。 max_consumer_per_broker String 每个Broker的最大消费者数。 min_broker String Broker的最小个数。
-
查询Kafka集群元数据信息 - 分布式消息服务Kafka版
consumers_count Integer 消费者总数。 表4 brokers参数说明 参数 类型 说明 host String 节点IP。 port Integer 端口号。 broker_id String 节点id。
-
查询Kafka实例的协调器信息 - 分布式消息服务Kafka版
id Integer 对应协调器的broker id。 host String 对应协调器的地址。 port Integer 端口号。
-
创建关闭实例转储节点的订单 - 分布式消息服务Kafka版
request = new CreateDeleteConnectorOrderRequest(); ConnectorOrderRequestBody body = new ConnectorOrderRequestBody(); body.withUrl
-
查询实例的扩容规格列表 - 分布式消息服务Kafka版
max_broker String Broker的最大个数。 max_storage_per_node String 每个节点的最大存储。单位为GB。 max_consumer_per_broker String 每个Broker的最大消费者数。