检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 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实例规格。
message_trace_enable,features.pod.token.access,feature.physerver.kafka.pulbic.dynamic,feature.physerver.kafka.user.manager", "trace_enable":
topic Topic名称。 type Leader所处的阶段，取值如下： ELECT_LEADER：选举Leader。 MAKE_LEADER：确定Leader。 leader Leader所在分区。 startOffset Leader在对应Epoch上写入第一条消息的Offset。
consumer不能频繁加入和退出group，频繁加入和退出，会导致consumer频繁做rebalance，阻塞消费。 同一消费组内consumer数量不能超过该消费组订阅的分区总数，否则会有consumer拉取不到消息。 consumer需周期poll，维持和server的心跳，
-file server.cert-signed 按照提示信息输入1中设置的keystore密码。 导出证书“server.keystore.jks”、“server.truststore.jks”和“client.truststore.jks”到本地PC机。 “server.keystore
过程如下（以3个代理为例介绍）： 停止Broker 0的Kafka进程。 扩容/缩容Broker 0的规格。 重启Broker 0的Kafka进程。 重复1~3，扩容/缩容Broker 1的规格。 重复1~3，扩容/缩容Broker 2的规格。 图2 扩容/缩容代理规格过程 变更Kafka集群实例规格
每个Kafka实例包含3个Zookeeper节点，Zookeeper集群用来管理Kafka实例的配置，如果Zookeeper集群出现问题，Kafka实例将无法正常运行。至少2个Zookeeper节点正常运行，才能保证Zookeeper集群正常运行。 假设选择2个可用区，可用区1有1个Zookeeper节点，可用
可能原因：在扩容/缩容代理规格的过程中，代理采用滚动重启的方式进行实例变更。在重启过程中，分区Leader会进行切换，此时生产客户端的元数据缓存中保存的分区Leader为旧分区Leader ID，仍然会向旧分区Leader发送消息，导致生产消息失败。 解决方法：在生产客户端配置重试机制。建议设置retries=10，retry
ssl-user-config.properties”文件，参考3增加用户名和密码，以及SSL证书配置。 在Kafka客户端的“/bin”目录下，通过以下命令查询消费者列表。 ./kafka-consumer-groups.sh --bootstrap-server {connection-address}
ResetUserPasswrodReq{ NewPassword: &newPasswordResetUserPasswrodReq, } response, err := client.ResetUserPasswrod(request) if err == nil
userNameUpdateUserReq:= "用户名" newPasswordUpdateUserReq:= "Cxxx3" request.Body = &model.UpdateUserReq{ UserDesc: &userDescUpdateUserReq,
盘写满的现象。 当CPU使用率过高时，系统的运行速度会降低，并有加速硬件损坏的风险。 当磁盘写满时，相应磁盘上的Kafka日志目录会出现offline问题。此时，该磁盘上的分区副本不可读写，降低了分区的可用性和容错能力。同时由于Leader分区迁移到其他节点，会增加其他节点的负载。
RI部分找到resource-path（/v3.0/OS-USER/users），拼接起来如下所示。 https://iam.cn-north-4.myhuaweicloud.com/v3.0/OS-USER/users 图1 URI示意图 为查看方便，在每个具体API的URI部
buffer.memory 33554432 67108864 producer可以用来缓存数据的内存大小。如果数据产生速度大于向broker发送的速度，producer会阻塞或者抛出异常，以“block.on.buffer.full”来表明。 这项设置将和producer能够使用
创建实例时为什么无法查看子网和安全组等信息？ 创建实例时，如果无法查看虚拟私有云、子网、安全组、弹性IP，可能原因是该用户的用户组无Server Administrator和VPC Administrator权限。增加用户组权限的详细步骤，请参考修改用户组权限。 父主题： 实例问题
用户可以订阅/发布此Topic，其他未授权的用户不能订阅/发布此Topic。“allow.everyone.if.no.acl.found”在配置参数中修改。 如果“allow.everyone.if.no.acl.found”为“false”，初始用户（即首次开启密文接入时设置
参数类型 描述 cluster cluster object 参数解释： 集群基本信息。 表3 cluster 参数 参数类型 描述 controller String 参数解释： 控制器ID。 取值范围： 不涉及。 brokers Array of brokers objects 参数解释：
不涉及。 percentage 否 String 占用磁盘大小，查询大于占比的分区。 请求参数 无 响应参数 状态码：200 表3 响应Body参数 参数 参数类型 描述 broker_list Array of DiskusageEntity objects Broker列表。 表4
消费者地址。 member_id 否 String 消费者ID。 请求参数 无 响应参数 状态码：200 表3 响应Body参数 参数 参数类型 描述 members Array of GroupMemberEntity objects 成员详情 total Integer 总数 表4 GroupMemberEntity
new_partition_brokers 否 Array of integers 增加分区时指定broker列表 topic_other_configs 否 Array of topic_other_configs objects Topic配置 topic_desc 否 String Topic描述
