检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
续费概述 续费简介 包年/包月Kafka实例到期后会影响Kafka实例正常运行。如果您想继续使用，需要在指定的时间内为Kafka实例续费，否则Kafka实例资源会自动释放，数据丢失且不可恢复。 续费操作仅适用于包年/包月Kafka实例，按需计费Kafka实例不需要续费，只需要保证账户余额充足即可。
历史API API V1 API V2
修订记录 发布日期 修订记录 2024-06-04 本次变更如下： 新增诊断管理相关接口。 2024-03-06 本次变更如下： 新增Smart Connect相关接口。 将转储相关接口移动至历史API。 2024-02-26 本次变更如下： 新增生产消息接口。 2023-11-10
生产消息失败 问题现象 系统提示“Disk error when trying to access log file on the disk”错误。 根因描述 节点磁盘使用率超高导致生产消息失败。 问题解决措施 扩容实例的磁盘空间，具体操作请参考变更Kafka实例规格。
测试实例性能 测试Kafka生产速率和CPU消耗 测试Kafka实例TPS
配置Topic 创建Kafka Topic 设置Kafka Topic权限 Topic管理
消息问题 Kafka生产消息的最大长度是多少？ 为什么Kafka实例常常发生Rebalance（重平衡），导致消息拉取失败？ 为什么Console页面上，消息查询查不到消息？ Kafka消息堆积了怎么办？ 消息超过老化时间，消息仍存在的原因 Kafka实例是否支持延迟消息？ 如何查看堆积消息数？
连接问题 选择和配置安全组 Kafka实例是否支持公网访问？ Kafka实例的连接地址默认有多少个？ 是否支持跨Region访问？ Kafka实例是否支持跨VPC访问？ Kafka实例是否支持不同的子网？ Kafka是否支持Kerberos认证，如何开启认证？ Kafka实例是否支持无密码访问？
典型应用场景 Kafka作为一款热门的消息队列中间件，具备高效可靠的消息异步传递机制，主要用于不同系统间的数据交流和传递，在企业解决方案、金融支付、电信、电子商务、社交、即时通信、视频、物联网、车联网等众多领域都有广泛应用。 异步通信 将业务中属于非核心或不重要的流程部分，使用消
查看Kafka消息 您可以查看指定Topic不同分区的偏移量、消息大小、创建时间以及消息正文。 查看Kafka消息 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，
删除Kafka消息 本章节介绍如何在控制台删除Topic中存储的消息。 删除Kafka消息须知 消息删除后无法恢复，请谨慎操作。 前提条件 删除消息前，请先在消费代码中设置“auto.offset.reset”参数。“auto.offset.reset”用来指定当Kafka中没有
Kafka Manager问题 登录Kafka Manager的账号是否可以设置为只读账号？ 登录到Kafka Manager页面，为什么获取不到节点信息？ Yikes! Insufficient partition balance when creating topic : p
Topic和分区问题 Kafka实例的Topic数量是否有限制？ 为什么限制Topic的总分区数？ Kafka支持减少分区数吗？ Kafka实例创建Topic失败 Kafka实例支持批量导入Topic功能么？或者是自动生成Topic功能？ 为什么删除Topic不生效？删除后该Topic仍然存在
按需计费 按需计费是一种先使用再付费的计费模式，适用于无需任何预付款或长期承诺的用户。本文将介绍按需计费Kafka实例的计费规则。 适用场景 按需计费适用于具有不能中断的短期、突增或不可预测的应用或服务，例如电商抢购、临时测试、科学计算。 适用计费项 分布式消息服务Kafka版对
API V1 实例管理类接口 实例使用类接口 其他接口 父主题： 历史API
API V2 查询产品规格列表 新增Kafka实例指定Topic分区 重置消费组消费进度到指定位置 修改转储任务的配额 创建关闭实例转储节点的订单 创建转储任务 查询转储任务列表 查询单个转储任务 删除单个转储任务 父主题： 历史API
认证鉴权 调用接口有如下两种认证方式，您可以选择其中一种进行认证鉴权。 AK/SK认证：通过AK（Access Key ID）/SK（Secret Access Key）加密调用请求。推荐使用AK/SK认证，其安全性比Token认证要高。 Token认证：通过Token认证调用请求。
Flink 1.15消费进度提交失败 问题现象 Flink 1.15版本消费Kafka时， 消费进度提交失败，持续报错：COORDINATOR_NOT_AVAILABLE。 根因描述 Flink 1.15版本使用的Kafka客户端存在bug，当某次消费进度提交失败后， 客户端将c
配置Kafka实例标签 标签是Kafka实例的标识，为Kafka实例添加标签，可以方便用户识别和管理拥有的Kafka实例资源。 您可以在创建Kafka实例时添加标签，也可以在Kafka实例创建完成后，在“标签”页面添加标签，您最多可以给实例添加20个标签。另外，您还可以删除标签。
诊断Kafka消息积压 在消息处理过程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息没有被及时消费就会产生消息堆积，从而会造成消息消费延迟。 分布式消息服务Kafka版在控制台提供了消息积压诊断功能，如果消息存在堆积，诊断
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
