文档中心
登录
注册
消息队列 Kafka版
文档指南
消息队列 Kafka版
消息队列 Kafka版
文档指南
请输入
产品动态
新功能发布记录
产品公告
消息队列 Kafka版正式商用通知
计算规格名称调整说明
产品介绍
什么是消息队列 Kafka版
产品优势
产品功能
产品规格
相关概念
地域及可用区
限制说明
消息队列|MQ
产品计费
计费概述
计费项
计费类型
按量计费
包年包月
转包年包月
实例续费
欠费或到期说明
退订或变配费用说明
税费及发票
快速入门
概述
准备环境
创建资源
连接实例
使用 PLAINTEXT 接入点连接实例
使用 SASL_PLAINTEXT 接入点连接实例
使用 SASL_SSL 接入点连接实例
使用 SSL 接入点连接实例
用户指南
实例管理
实例生命周期管理
创建实例
查看实例详情
升级实例规格
删除实例
重启实例
连接管理
添加接入点
查看接入点
配置公网访问
设置公网解析
删除接入点
实例运维
修改参数配置
查看节点信息
设置磁盘清理水位
操作审计
实例标签管理
实例标签概述
绑定标签
根据标签筛选实例
编辑和解绑标签
Topic 管理
创建 Topic
批量导入 Topic
导出 Topic 列表
修改 Topic 配置
管理 Topic 标签
查看 Topic 详情
删除 Topic
在线调试
限流管理
添加限流
修改限流
删除限流
Group 管理
创建 Group
批量导入 Group
导出 Group 列表
管理 Group 标签
查看 Group 详情
重置消费位点
删除 Group
消息查询
用户管理
创建 SASL 用户
批量导入 SASL 用户
重置 SASL 用户密码
查看 PLAIN 用户密码
删除 SASL 用户
ACL 管理
创建 ACL
删除 ACL
后台任务管理
监控告警
查看监控数据
设置告警规则
推荐配置的告警规则
访问控制
基于 IAM 管理权限
可授权的资源和操作
跨服务访问
访问策略模板
白名单管理
创建白名单
为白名单绑定实例
为白名单解绑实例
查看白名单信息
修改白名单
删除白名单
集群迁移
集群迁移概述
创建迁移任务
迁移元数据
在线迁移元数据
离线迁移元数据
导入元数据
修改迁移数据配置
查看迁移命令
删除迁移任务
Kafka Agent
Kafka Agent 概述
使用 Kafka Agent
API 参考
API 版本说明
V2(2022-05-01)
使用前必读
API 概览
如何调用 API
请求结构
服务地址
签名机制
返回结果
公共参数
资源检查
DescribeRegions - 查看地域列表
DescribeAvailabilityZones - 查看可用区列表
实例管理
CreateInstance - 创建实例
DescribeInstances - 查看实例列表
DescribeInstanceDetail - 查看实例详情
DeleteInstance - 删除实例
ModifyInstanceAttributes - 修改实例基本信息
ModifyInstanceSpec - 变更实例规格
ModifyInstanceParameters - 修改实例参数
ModifyInstanceChargeType - 变更实例的计费类型
网络管理
CreatePublicAddress - 开启公网访问
DeletePublicAddress - 关闭公网访问
Topic 管理
CreateTopic - 创建 Topic
DeleteTopic - 删除 Topic
ModifyTopicAttributes - 修改 Topic 描述
ModifyTopicParameters - 修改 Topic 参数配置
ModifyTopicAccessPolicies - 修改 Topic 的用户权限
DescribeTopics - 查看 Topic 列表
DescribeTopicParameters - 查看 Topic 的参数配置
DescribeTopicPartitions - 查看 Topic 分区
DescribeTopicAccessPolicies - 查看 Topic 的权限列表
Group 管理
CreateGroup - 创建Group
ModifyGroup - 更新消费组
DeleteGroup - 删除 Group
DescribeGroups - 查看 Group 列表
DescribeConsumedTopics - 查看 Group 订阅的 Topic
DescribeConsumedPartitions - 查看 Group 订阅的分区
ResetConsumedOffsets - 重置消费位点
消息查询
QueryMessageByTimestamp - 根据时间查询消息
SASL 用户管理
CreateUser - 创建 SASL 用户
DeleteUser - 删除 SASL 用户
ModifyUserAuthority - 更改 SASL 用户默认权限
DescribeUsers - 查看 SASL 用户列表
ACL策略管理
CreateAcl - 创建ACL策略
DescribeAcls - 查询ACL策略
DeleteAcl - 删除ACL策略
操作审计
DescribeTopicAuditInfo - 查询主题审计信息
标签管理
AddTagsToResource - 添加实例标签
RemoveTagsFromResource - 解绑实例标签
DescribeTagsByResource - 查询实例标签
白名单管理
CreateAllowList - 新建白名单
ModifyAllowList - 修改白名单
DeleteAllowList - 删除白名单
DescribeAllowLists - 查询白名单列表
DescribeAllowListDetail - 查询白名单详情
AssociateAllowList - 绑定白名单
DisassociateAllowList - 解绑白名单
附录
请求幂等性
V1(2018-01-01)
使用前必读
如何调用 API
请求结构
服务地址
签名机制
返回结果
公共参数
API 概览
实例管理
ListKafkaConf
CreateKafkaInstance
DeleteKafkaInstance
DescribeInstanceDetail
DescribeInstancesSummary
ModifyInstanceDescription
ModifyInstanceName
ModifyInstanceParams
ModifyChargeToPrepaid
ScaleKafkaInstance
EnableInternetAccess
DisableInternetAccess
Topic 管理
CreateTopic
DeleteTopic
DescribeTopics
DescribeTopicAuthorities
DescribeTopicPartitions
ModifyTopic
ModifyTopicAuthorities
QueryMessageByMessageId
Group 管理
DeleteGroup
DescribeConsumedPartitions
DescribeConsumedTopics
DescribeGroups
ResetConsumedOffsets
SASL 用户管理
CreateSaslUser
DescribeSaslUsers
DeleteSaslUser
ModifySaslPassword
ModifyUserAuthority
附录
数据结构
错误码
SDK 参考
概述
Apache Kafka SDK
Java 客户端 SDK
概述
准备工作
PLAINTEXT 接入点收发消息
SASL_PLAINTEXT 接入点 PLAIN 机制收发消息
SASL_PLAINTEXT 接入点 SCRAM 机制收发消息
SASL_SSL 接入点 PLAIN 机制收发消息
SASL_SSL 接入点 SCRAM 机制收发消息
配置文件
Go 客户端 SDK
概述
准备工作
PLAINTEXT 接入点收发消息
SASL_PLAINTEXT 接入点 PLAIN 机制收发消息
SASL_PLAINTEXT 接入点 SCRAM 机制收发消息
SASL_SSL 接入点 PLAIN 机制收发消息
SASL_SSL 接入点 SCRAM 机制收发消息
SDK 配置说明
Python 客户端 SDK
概述
准备工作
PLAINTEXT 接入点收发消息
SASL_PLAINTEXT 接入点 PLAIN 机制收发消息
SASL_PLAINTEXT 接入点 SCRAM 机制收发消息
SASL_SSL 接入点 PLAIN 机制收发消息
SASL_SSL 接入点 SCRAM 机制收发消息
SDK 配置说明
C++ 客户端 SDK
概述
准备工作
PLAINTEXT 接入点收发消息
SASL_PLAINTEXT 接入点 PLAIN 机制收发消息
SASL_PLAINTEXT 接入点 SCRAM 机制收发消息
SASL_SSL 接入点 PLAIN 机制收发消息
SASL_SSL 接入点 SCRAM 机制收发消息
Volcengine SDK
概述
Volcengine Go SDK
Go SDK 概述
安装 Go SDK
快速开始
Volcengine Python SDK
Python SDK 概述
安装 Python SDK
快速开始
Volcengine Java SDK
Java SDK 概述
安装 Java SDK
快速开始
最佳实践
Kafka 业务迁移
迁移概述
Kafka 迁移上云(方案一)
Kafka 迁移上云(方案二)
查看迁移进度和结果
Topic 使用建议
Kafka 生产者最佳实践
Kafka 消费者最佳实践
消息顺序性与可靠性
Kafka 集群数据均衡
多可用区部署 Kafka 实例
Kafka CPU 消耗场景分析
接入 Filebeat
通过函数服务消费消息队列 Kafka 版
对 Kafka 进行生产和消费压力测试
概述
使用 PLAINTEXT 接入点进行压力测试
使用 SASL_PLAINTEXT 接入点进行压力测试
使用 SASL_SSL 接入点进行压力测试
数据压缩算法推荐
常见问题
实例配置FAQ
实例连接FAQ
Topic和Group管理FAQ
资源与成本管理FAQ
消息收发与存储FAQ
相关协议
产品和服务测试协议
中间件产品服务条款
消息队列服务等级协议(SLA)
文档首页
消息队列 Kafka版
产品动态
新功能发布记录
复制全文
下载 pdf
我的收藏
产品动态
新功能发布记录
复制全文
下载 pdf
我的收藏
新功能发布记录
文档反馈
问问助手
本文介绍了消息队列 Kafka 版各特性版本的功能发布动态和文档变更动态。
说明
如需查看历年发布记录,详情参考
新功能发布记录(2022-2024年)
。
2025年7月
功能名称
功能描述
发布地域
相关文档
提供大流量实例规格
提供 4GB 以上实例规格,包括 6GB、8GB、10GB 大流量规格,并同时提供高写和高读两个版本。
全部地域
产品规格
大流量规格存储类型新增支持 ESSD_PL0
创建实例时,大流量规格的存储类型除了 ESSD_FlexPL 之外,还可以选择 ESSD_PL0 盘,降低成本。
全部地域
创建实例
关闭事务功能
提供全局关闭事务功能,可以实例层面整体关闭事务,避免使用者误使用导致性能降低。
全部地域
查看实例详情
2025年6月
功能名称
功能描述
发布地域
相关文档
提供 Regional 域名
提供带地域标识的 Regional 域名,便于实现跨 Region 访问,新建实例上可使用,存量实例按需开启。
全部地域
查看接入点
增加剩余数据显示
实例详情中,显示 Topic 及消费组的剩余可用数量。
全部地域
查看实例详情
Group 管理增加按状态筛选和排序功能
在 Group 管理的 Group 状态上增加筛选和排序功能。
全部地域
查看 Group 详情
2025年5月
功能名称
功能描述
发布地域
相关文档
Group 详情增加全局刷新功能按钮
通过全局刷新按钮,实现概览的消息堆积量以及各分区的消息堆积量的同步刷新。
全部地域
查看 Group 详情
使用消息查询功能时,按分区 ID 搜索分区
在使用消息查询功能时,提供按照分区 ID 来搜索分区的功能,便于在分区数较多时,快速定位分区 ID。
全部地域
消息查询
提供小流量高读版实例规格
在已有高读版规格的基础上,新增 kafka.20xrate.hr 至 kafka.600xrate.hr 之间的高读版实例规格。
全部地域
产品规格
2025年4月
功能名称
功能描述
发布地域
相关文档
可跳转至关联的数据集成产品页面
通过 Kafka 页面,跳转至可与 Kafka 做数据集成的相关产品页面,包括 TLS、云搜索服务以及 DTS。
全部地域
无
优化服务端返回码
服务端优化错误码返回,如果遇到没权限,优先返回 not coordinator,触发客户端自动寻找新的 coordinator。
全部地域
无
网络接入点功能升级
提供更丰富的网络接入点操作功能,可删除默认接入点,可设置跨 VPC 访问接入点等。
全部地域
添加接入点
查看接入点
删除接入点
最近更新时间:2026.05.07 14:25:39
这个页面对您有帮助吗?
有用
有用
无用
无用