分布式消息服务Kafka版
分布式消息服务Kafka版
本产品内“
”的所有结果
本产品内“
”的所有结果
最新动态
功能总览
服务公告
产品公告
【下线公告】华为分布式消息服务Kafka版2.3.0版本停售公告
漏洞公告
漏洞修复策略
版本公告
版本支持公告
版本发布说明
产品介绍
图解Kafka、RabbitMQ和RocketMQ的差异
什么是分布式消息服务Kafka版
产品优势
典型应用场景
Kafka实例规格
Kafka单机实例
Kafka集群实例
单机和集群Kafka实例差异概述
与RabbitMQ、RocketMQ的差异
与开源Kafka的差异
安全
责任共担
身份认证与访问控制
数据保护技术
审计与日志
服务韧性
监控安全风险
认证证书
约束与限制
与其他云服务的关系
Kafka相关概念
权限管理
计费说明
分布式消息服务Kafka版计费概述
计费模式
分布式消息服务Kafka版计费模式概述
包年/包月
按需计费
计费项
计费样例
变更计费模式
变更计费模式概述
按需转包年/包月
包年/包月转按需
续费
续费概述
手动续费
自动续费
费用账单
欠费说明
停止计费
成本管理
快速入门
快速连接Kafka并生产消费消息
入门实践
用户指南
Kafka业务使用流程
权限管理
创建用户并授权使用DMS for Kafka
购买Kafka实例
配置Topic
创建Kafka Topic
设置Kafka Topic权限
Topic管理
查看Kafka Topic详情
查看Kafka Topic日志
修改Kafka Topic配置
修改Kafka Topic分区数
修改Kafka Topic副本数
导出Kafka Topic列表
修改Kafka分区平衡
配置Kafka自动创建Topic
删除Kafka Topic
连接实例
配置Kafka网络连接
连接Kafka网络要求
配置Kafka实例的公网访问
使用VPCEP实现跨VPC访问Kafka
使用DNAT实现公网访问Kafka
配置Kafka访问控制
配置Kafka实例的明文/密文接入
制作和替换Kafka JKS格式的SSL证书
获取和使用Kafka PEM格式的SSL证书
配置Kafka的SSL双向认证
配置Kafka ACL用户
配置Kafka客户端
Kafka客户端参数配置建议
Kafka客户端使用建议
使用客户端连接Kafka（明文接入）
使用客户端连接Kafka（密文接入）
使用控制台连接Kafka
管理消息
查看Kafka消息
修改Kafka消息老化时间
删除Kafka消息
诊断Kafka消息积压
管理消费组
创建Kafka消费组
查看Kafka消费组信息
查看Kafka消费者信息
查看和重置Kafka消费进度
查看Kafka重平衡日志
修改Kafka消费组信息
配置Kafka自动创建消费组
导出Kafka消费组列表
删除Kafka消费组
取消Kafka消费组和Topic的订阅关系
配置流控
配置Kafka流控
查看Kafka流控统计
管理实例
查看和修改Kafka实例基本信息
查看Kafka磁盘使用量
查看Kafka实例后台任务
查看Kafka生产消费示例代码
修改Kafka实例配置参数
配置Kafka实例标签
配置Kafka实例回收站策略
升级Kafka实例内核版本
导出Kafka实例列表
重启Kafka实例
删除Kafka实例
管理Kafka Manager
访问Kafka Manager
重置Kafka Manager密码
重启Kafka Manager
关闭Kafka Manager
变更实例规格
变更Kafka集群实例规格
自动扩容Kafka实例存储空间
迁移数据
Kafka数据迁移概述
使用MirrorMaker跨集群同步数据
使用Smart Connect迁移数据
开启Smart Connect
配置Kafka间的数据复制
配置Kafka数据转储至OBS
管理Smart Connect任务
关闭Smart Connect
测试实例性能
测试Kafka生产速率和CPU消耗
测试Kafka实例TPS
申请扩大Kafka配额
查看监控指标与配置告警
查看Kafka监控数据
Kafka支持的监控指标
配置Kafka监控告警
查看Kafka审计日志
最佳实践
Kafka最佳实践汇总
提高Kafka消息处理效率
Logstash对接Kafka生产消费消息
使用MirrorMaker跨集群同步数据
消息堆积处理建议
业务过载处理建议
业务数据不均衡处理建议
Kafka Topic分区数设置建议
配置消息堆积数监控
DMS for Kafka安全使用建议
优化消费者轮询（Polling）
开发指南
概述
收集连接信息
Java
Java客户端接入示例
Java开发环境搭建
Python
Go
获取Kafka开源客户端
spring-kafka的使用
API参考
使用前必读
API概览
如何调用API
构造请求
认证鉴权
返回结果
快速入门
API V2（推荐）
生命周期管理
创建Kafka实例
查询所有实例列表
查询指定实例
删除指定的实例
修改实例信息
批量重启或删除实例
获取实例配置
修改实例配置
实例升级
实例管理
重置密码
重置Manager密码
重启Manager
修改实例跨VPC访问的内网IP
查询Kafka集群元数据信息
查询Kafka实例的协调器信息
修改Kafka的接入方式
查询topic的磁盘存储情况
关闭Kafka Manager
删除用户/客户端流控配置
查询用户/客户端流控配置
创建用户/客户端流控配置
修改用户/客户端流控配置
查询Kafka实例重平衡日志详情
开启Kafka实例重平衡日志功能
关闭Kafka实例重平衡日志功能
Smart Connect
开启Smart Connect（按需实例）
关闭Smart Connect（按需实例）
创建Smart Connect任务
查询Smart Connect任务列表
查询Smart Connect任务详情
删除Smart Connect任务
修改Smart Connect任务配置
校验Connector连通性
暂停Smart Connect任务
启动已暂停的Smart Connect任务
启动未启动的Smart Connect任务/重启已暂停或者运行中的Smart Connect任务
规格变更管理
实例扩容
查询实例的扩容规格列表
主题管理
开启或关闭实例自动创建Topic功能
修改Kafka实例Topic分区的副本
Kafka生产消息
Kafka实例创建Topic
Kafka实例查询Topic
修改Kafka实例Topic
Kafka实例批量删除Topic
查询Topic的分区列表
查询Topic的当前生产者列表
查询Kafka实例Topic详细信息
删除Topic流控配置
创建Topic流控配置
修改Topic流控配置
查询Topic流控配置
Kafka实例开始分区平衡任务
消费组管理
查询消费组信息
查询所有消费组
Kafka实例批量删除消费组
创建消费组
重置消费组消费进度到指定位置
查询消费组消息位点
修改所有消费组
查询指定消费组
删除指定消费组
修改指定消费组
查询指定消费组的Topic
删除消费组在指定Topic的消费位点
查询指定消费组的消费成员
用户管理
查询用户列表
创建用户
批量删除用户
重置用户密码
修改用户参数
查询用户权限
设置用户权限
消息管理
查询消息
查询分区指定偏移量的消息
查询分区指定时间段的消息
查询分区最早消息的位置
查询分区最新消息的位置
Kafka删除消息
后台任务管理
查询实例的后台任务列表
查询后台任务管理中的指定记录
删除后台任务管理中的指定记录
标签管理
批量添加或删除实例标签
查询实例标签
查询项目标签
诊断管理
消息积压诊断预检查
创建消息积压诊断任务
查询消息积压诊断报告列表
批量删除消息积压诊断报告
查询诊断报告详情
其他接口
查询维护时间窗时间段
查询可用区信息
查询产品规格列表
查询实例在CES的监控层级关系
查询Kafka产品规格核数
权限和授权项
历史API
API V1
实例管理类接口
创建Kafka实例
查询指定实例
修改实例信息
删除指定实例
批量重启、删除实例
查询所有实例列表
Kafka实例创建Topic
Kafka实例查询Topic
Kafka实例批量删除Topic
实例使用类接口
查询分区指定偏移量的消息
查询分区指定时间段的消息
查询分区最新消息的位置
查询分区最早消息的位置
查询Kafka集群元数据信息
查询消费组信息
重置消费组消费进度到指定位置
查询Kafka实例所有消费组对应的协调器信息
查询Kafka实例Topic详细信息
新增Kafka实例指定Topic分区
调整Kafka实例Topic分区的副本
其他接口
查询可用区信息
查询产品规格列表
查询维护时间窗时间段
查询实例在CES的监控层级关系
查询实例在CES的监控层级关系
查询配额
API V2
生命周期管理
创建实例
查询指定实例
实例管理
新增Kafka实例指定Topic分区
Kafka实例开始分区平衡任务
消费组管理
重置消费组消费进度到指定位置
查询所有消费组
Smart Connect
修改转储任务的配额
创建关闭实例转储节点的订单
创建转储任务
查询转储任务列表
查询单个转储任务
删除单个转储任务
规格变更管理
查询实例的扩容规格列表
实例扩容
其他接口
查询产品规格列表
附录
状态码
错误码
实例状态说明
获取项目ID
获取账号名和账号ID
修订记录
SDK参考
SDK概述
常见问题
实例问题
为什么可用区不能选择2个？
创建实例时为什么无法查看子网和安全组等信息？
如何选择Kafka实例的存储空间？
Kafka实例的超高IO和高IO如何选择？
如何选择Kafka实例存储容量阈值策略？
Kafka服务端支持版本是多少？
Kafka实例的ZK地址是什么？
创建的Kafka实例是集群模式么？
Kafka实例是否支持修改访问端口？
Kafka实例的SSL证书有效期多长？
如何将Kafka实例中的数据同步到另一个Kafka实例中？
Kafka实例的SASL_SSL开关如何修改？
SASL认证机制如何修改？
如何修改安全协议？
修改企业项目，是否会导致Kafka重启？
100MB/s的带宽怎样开启公网访问？
Kafka服务和ZK是部署在相同的虚拟机中，还是分开部署？
Kafka包周期实例支持删除吗？
Kafka支持哪些加密套件？
购买实例时选择的单AZ，怎样可以扩展为多AZ？
Kafka是否支持跨AZ容灾？已经购买的实例在哪里查看是否为跨AZ？
Kafka支持磁盘加密吗？
Kafka实例创建后，能修改VPC和子网吗？
有没有Kafka Stream的案例？
Kafka实例版本可以升级吗？
怎样重新绑定公网IP？
配置了“自动删除”策略，磁盘容量到达95%时，为什么没有自动删除最早的消息？
实例规格变更问题
Kafka扩容/缩容会影响业务吗？
扩容过程中涉及数据迁移吗？
扩容/缩容过程中生产消息失败
扩容失败提示资源不足
连接问题
选择和配置安全组
Kafka实例是否支持公网访问？
Kafka实例的连接地址默认有多少个？
是否支持跨Region访问？
Kafka实例是否支持跨VPC访问？
Kafka实例是否支持不同的子网？
Kafka是否支持Kerberos认证，如何开启认证？
Kafka实例是否支持无密码访问？
开启公网访问后，在哪查看公网IP地址？
Kafka支持服务端认证客户端吗？
连接开启SASL_SSL的Kafka实例时，ssl truststore文件可以用PEM格式的吗？
下载的证书JKS和CRT有什么区别？
Kafka支持哪个版本的TLS？
Kafka实例连接数有限制吗？
客户端单IP连接的个数为多少？
Kafka实例的内网连接地址可以修改吗？
不同实例中，使用的SSL证书是否一样？
为什么不建议使用Sarama客户端收发消息？
Topic和分区问题
Kafka实例的Topic数量是否有限制？
为什么限制Topic的总分区数？
Kafka支持减少分区数吗？
Kafka实例创建Topic失败
Kafka实例支持批量导入Topic功能么？或者是自动生成Topic功能？
Kafka实例是否支持查看单个Topic占用磁盘空间？
Topic是否支持ACL权限配置？
消息被消费后，没有删除，导致Kafka存储空间占满？
如何扩总分区？
修改自动创建Topic的配置，会触发重启吗？
消费者消费Topic失败，提示没有权限？
分区数可以单独买吗？
消费组问题
Kafka实例是否需要创建消费组、生产者和消费者？
如果消息组中没有在线的消费者（如empty状态），是否14天后会自动被删除？
为什么删除消费组不生效？
实例消费正常，为什么看不到消费者？
Kafka可以删除消费组下不用的Topic吗？
为什么创建的消费组不见了？
消息问题
Kafka生产消息的最大长度是多少？
为什么Kafka实例常常发生Rebalance（重平衡），导致消息拉取失败？
为什么Console页面上，消息查询查不到消息？
Kafka消息堆积了怎么办？
消息超过老化时间，消息仍存在的原因
Kafka实例是否支持延迟消息？
如何查看堆积消息数？
为什么消息创建时间显示1970？
如何修改message.max.bytes参数？
为什么offset不连续？
Kafka Manager问题
登录Kafka Manager的账号是否可以设置为只读账号？
登录到Kafka Manager页面，为什么获取不到节点信息？
Yikes! Insufficient partition balance when creating topic : projectman_project_enterprise_project Try again.
Kafka Manager能否查询到消息的正文？
Kafka Manager WebUI的端口能否修改？
在Kafka Manager上支持修改Topic的哪些属性？
Kafka Manager和云监控显示的信息不一致
Kafka Manager如何修改Topic的分区Leader？
实例版本在控制台和Kafka Manager上显示不一致？
为什么实例中存在默认名为__trace和__consumer_offsets的Topic？
客户端删除消费组后，在Kafka Manager中仍可以看到此消费组？
监控告警问题
云监控无法展示Kafka监控数据
Kafka监控显示消息堆积数跟实例里的消息数不一致？
Kafka的消费组删除了，怎么监控页面还可以看到这个消费组？
为什么磁盘读/写流量、磁盘平均读/写操作耗时和CPU使用率出现明显波动？
为什么JVM堆内存使用率出现明显波动？
生产消息数不为0，为什么生产速率为0？
消费进度显示有堆积消息，为什么监控中显示消息堆积数为0？
Kafka体验版使用说明
故障排除
Kafka连接问题排查和解决
消息从生产到消费时延高达6分钟
生产消息失败
删除Topic失败
在Windows服务器中无法登录Kafka Manager
生产或消费消息时，报Topic {{topic_name}} not present in metadata after 60000 ms错误
Flink 1.15消费进度提交失败
视频帮助
文档下载
通用参考
产品术语
云服务等级协议（SLA）
白皮书资源
支持区域
系统权限