检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
的时候将Token加到请求消息头，从而通过身份认证，获得操作API的权限。Token可通过调用获取用户Token接口获取。 云服务存在两种部署方式：项目级服务和全局级服务。其中： 项目级服务需要获取项目级别的Token，此时请求body中auth.scope的取值为project。
使用对等连接跨VPC访问，访问端口为9093。 DNAT访问，访问端口为9011。 在访问Kafka实例之前，需要确保安全组是否配置正确，配置要求，请参考选择和配置安全组。 父主题： 实例问题
加SASL认证的“consumer.properties”配置文件参数： --command-config {SASL认证的consumer.properties配置文件}，“consumer.properties”配置文件参考使用客户端连接Kafka（开启SASL）。 父主题：
String 配置名称 valid_values String 配置有效值 default_value String 配置默认值 config_type String 配置类型：dynamic/static value String 配置值 value_type String 配置值类型
threads和num.replica.fetchers的配置。 num.io.threads和num.network.threads建议配置为磁盘个数的倍数，但不能超过CPU核数。 num.replica.fetchers建议配置不超过5。 合理设置Topic的分区，分区一般设置为节点个数的倍数。
业务过载处理建议 本章节描述了CPU使用率高和磁盘写满的原因，以及处理措施。 业务数据不均衡处理建议 本章节描述了业务数据不均衡的原因，以及处理措施。 配置消息堆积数监控 本章节介绍如何创建消息堆积数超过阈值的告警规则，实现消息堆积数超过阈值时，系统自动发送短信/邮件通知用户，让用户能够实时掌握业务的运行情况。
description String 否 实例的描述信息。 长度不超过1024的字符串。 说明： \与"在json报文中属于特殊字符，如果参数值中需要显示\或者"字符，请在字符前增加转义字符\，比如\\或者\"。 engine String 是 消息引擎。取值填写为：kafka。 engine_version
Kafka服务和ZK是部署在相同的虚拟机中，还是分开部署？ Kafka服务和ZK部署在相同的虚拟机中。 父主题： 实例问题
上角的“更多 > 转包周期”，跳转到“按需转包年/包月”页面。 选择Kafka实例的购买时长，判断是否勾选“自动续费”，确认预计到期时间和配置费用后单击“去支付”。 图1 按需转包年/包月 进入支付页面，选择支付方式，确认付款，支付订单后即可完成按需转包年/包月。 父主题： 变更计费模式
全组与Kafka实例保持一致，Linux系统），具体步骤请参考购买弹性云服务器。 购买完成ECS后，需要在ECS中完成以下配置： 安装Java JDK，并配置JAVA_HOME与PATH环境变量。 export JAVA_HOME=/root/jdk1.8.0_231 export
欠费说明 用户在使用云服务时，账户的可用额度小于待结算的账单，即被判定为账户欠费。欠费后，可能会影响云服务资源的正常运行，请及时充值。 欠费原因 购买了按需计费Kafka实例，并使用了一段时间后，账户的余额不足。 欠费影响 包年/包月 对于包年/包月Kafka实例，用户已经预先支
fsets.retention.minutes，offsets.retention.minutes支持在控制台修改，具体修改方法请参考修改配置参数。 2023年4月25日及之后创建的实例，分为以下几种情况： auto.create.groups.enable为false时，消费组
policiesOnly Boolean 是否为默认策略。 id String Topic名称 replication Integer 副本数，配置数据的可靠性 partition Integer Topic分区数，设置消费的并发数。 retention_time Integer 消息老化时间。
性。 稳定性高，基于librdkafka，具有高性能和低延迟的特点。 增加编译复杂度。由于导入C++库，Golang编译器需要引入额外编译配置，增加了编译依赖，提高编译复杂度。 Kafka-go kafka-go是一个简单、轻量级的Kafka客户端库，易于学习和使用。 kafka
enable”为“false”时，需要手动创建消费组，不需要单独创建生产者和消费者。 修改“auto.create.groups.enable”的方法，请参考修改Kafka实例配置参数。 连接Kafka实例后，生产消息和消费消息，请参考向Kafka实例生产消息和消费消息。 父主题： 消费组问题
开通自动续费后，还可以手动续费该Kafka实例。手动续费后，自动续费仍然有效，在新的到期时间前的第7天开始扣款。 自动续费的到期前7日自动扣款属于系统默认配置，您也可以根据需要修改此扣款日，如到期前6日、到期前5日等等。 更多关于自动续费的规则介绍请参见自动续费规则说明。 前提条件 请确认包年/包月Kafka实例还未到期。
消息积压诊断”，进入消息积压诊断页面。 选择需要诊断的消费组名称和Topic名称，单击“诊断前检查”。 诊断前检查成功后，如果“消息积压情况”显示有消息积压，并且消费组正在以非assign方式消费消息中，单击“开始诊断”。 诊断成功后，在诊断记录所在行，单击“查看详情”，进入“诊断详
其中，副本数在创建Topic时可以选择，默认为3副本存储。如果开启了Kafka自动创建Topic功能，自动创建的Topic默认为3副本，副本数可以通过“配置参数”页签中的“default.replication.factor”修改。 父主题： 实例问题
1.0和2.7 2022年11月 控制台支持手动、自动分区平衡 1.1.0和2.7 2022年9月 控制台支持修改最大连接数限制 实例支持配置磁盘容量阈值策略 父主题： 版本公告
修改分区平衡 × √ 设置Topic权限 × √ 用户管理 × √ 查看重平衡日志 × √ Smart Connect × √ 流控管理 × √ 修改配置参数 × √
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
