检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Kafka实例是否支持无密码访问？ 支持，连接明文接入的Kafka实例时，无需密码。具体操作，请参考使用客户端连接Kafka（关闭SASL）。 父主题： 连接问题
当您购买了Kafka实例后，可以根据自身的业务需求使用分布式消息服务Kafka版提供的一系列常用实践。 表1 常用最佳实践 实践 描述 使用MirrorMaker跨集群同步数据 使用MirrorMaker可以实现将源集群中的数据镜像复制到目标集群中。 配置消息堆积数监控 介绍如何设置消息组的消息堆积数超过
在左侧导航栏，单击“消费组管理”，进入消费组列表页面。 查看消息堆积的消费组是否有消费者在消费，如果有，让业务方加快消费效率，如果没有，让客户酌情删掉不使用的消费组。 处理方法2： 登录Kafka实例控制台，单击产生告警的实例名称，进入实例详情页。 在左侧导航栏，选择“分析与诊断 > 消息积压诊断”，进入消息积压诊断页面。
本文汇总了基于分布式消息服务Kafka版常见应用场景的操作实践，为每个实践提供详细的方案描述和操作指导，帮助用户轻松使用Kafka。 表1 Kafka最佳实践一览表 最佳实践 说明 提高Kafka消息处理效率 本章节提供了生产者和消费者对于消息的使用建议，以提高消息发送和消息消费的效率与可靠性。 优化消费者轮询（Polling）
生产和消费消息，但是会删除最早的10%的消息，以保证磁盘容量充足。该场景优先保障业务不中断，数据可能会丢失。 以上两种策略需要基于业务对数据和业务的可靠性来进行选择，只能作为极端场景下的一种处理方式。建议业务购买时保证有充足的磁盘容量，避免磁盘的使用达到容量阈值。 父主题： 实例问题
权限管理 创建用户并授权使用DMS for Kafka
以帮助您安全的控制华为云资源的访问。 通过IAM，您可以在账号中给员工创建IAM用户，并使用策略来控制他们对华为云资源的访问范围。例如您的员工中有负责软件开发的人员，您希望他们拥有DMS for Kafka的使用权限，但是不希望他们拥有删除Kafka实例等高危操作的权限，那么您可
算金额的80%时发送预算告警。那么，创建的预算如下： 图4 设置预算信息 图5 设置预算范围 详细介绍请参见使用预测和预算来跟踪成本和使用量。 资源优化 您可以通过云监控服务监控资源的使用情况，识别空闲资源，寻找节约成本的机会。也可以根据成本分析阶段的分析结果识别成本偏高的资源，然后采取针对性的优化措施。
er）。 Kafka的主题和分区属于逻辑概念，副本与代理属于物理概念。下图通过消息的生产与消费流向，解释了Kafka的分区、代理与主题间的关系。 图1 Kafka消息流 老化时间 消息的最长保留时间，消费者必须在此时间结束前消费消息，否则消息将被删除。删除的消息，无法被消费。
Kafka）是一款基于开源社区版Kafka提供的消息队列服务，向用户提供计算、存储和带宽资源独占式的Kafka专享实例。 免费体验 图说Kafka 立即使用 成长地图 由浅入深，带您玩转Kafka 01 了解 了解分布式消息服务Kafka版的产品特点和业务使用场景，有助于您更准确地匹配实际业务，更快速地选择所需实例。
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询可用区信息成功。 错误码 请参见错误码。 父主题：
Manager能否查询到消息的正文？ Kafka Manager WebUI的端口能否修改？ 在Kafka Manager上支持修改Topic的哪些属性？ Kafka Manager和云监控显示的信息不一致 Kafka Manager如何修改Topic的分区Leader？ 实例版本在控制台和Kafka
带宽速率：统计带宽速率大于x MB/s的用户/客户端/Topic，x由您自行输入。 带宽使用量：统计带宽使用量超过x %的用户/客户端/Topic，x由您自行输入。 统计类型 设置带宽使用量的统计类型。 生产：统计生产消息的带宽使用量。 消费：统计消费消息的带宽使用量。 统计维度 设置带宽使用量的统计维度。
约束与限制 本章节介绍分布式消息服务Kafka版产品功能的约束和限制，您在使用Kafka实例时注意不要超过相应的约束和限制，以免程序出现异常。 如果因为您的实例配置超过相应的约束和限制而导致的任何不稳定情况，不在SLA承诺和赔偿范围内。 实例 表1 实例约束与限制 限制项 约束与限制
pic的数据量和CPU使用率可以通过监控页面的“队列数据容量”和“CPU使用率”查看，具体步骤请参考查看Kafka监控数据。 带宽限制是指设定Topic进行副本同步的带宽上限，确保不会对该实例上的其他Topic造成流量冲击。但需要注意，带宽限制不会区分是正常的生产消息造成的副本同
通过以下几个场景，测试不同实例规格的TPS。 测试场景一（实例是否开启SASL）：相同的Topic，实例分为开启SASL和未开启SASL 测试场景二（同步/异步复制）：相同的实例，不同复制机制的Topic 测试场景三（是否同步落盘）：相同的实例，不同落盘机制的Topic 测试场景四（不同
when trying to access log file on the disk”错误。 根因描述 节点磁盘使用率超高导致生产消息失败。 问题解决措施 扩容实例的磁盘空间，具体操作请参考变更Kafka实例规格。
bytes参数？ 在Kafka控制台的“配置参数”页面修改message.max.bytes参数，具体步骤请参见修改Kafka实例配置参数。 message.max.bytes参数最大只能修改为10485760字节，如果您实际的业务场景中单条消息的大小超过此值，建议使用压缩算法或者业务逻辑做切分。
为成功的副本的最小数量。 1 ~ 3 1 message.max.bytes 单条消息的最大长度。 0 ~ 10485760 单位：字节 10485760 unclean.leader.election.enable 指示是否启用不在ISR集合中的副本选为领导者作为最后的手段，即使这样做可能导致数据丢失。
Kafka实例支持多种语言的客户端，如果您想要使用其他语言连接Kafka实例，可以从Kafka官网获取客户端。 Kafka官网支持的客户端语言包括：C/C++、Python、Go、PHP、Node.js等等。 Kafka实例完全兼容开源客户端，按照Kafka官网提供的连接说明，与Kafka实例对接。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
