分布式消息服务Kafka版
分布式消息服务Kafka版
- 最新动态
- 功能总览
- 服务公告
- 产品介绍
- 计费说明
- 快速入门
- 用户指南
- 最佳实践
- 开发指南
- API参考
- SDK参考
-
常见问题
-
实例问题
- 为什么可用区不能选择2个？
- 创建实例时为什么无法查看子网和安全组等信息？
- 如何选择Kafka实例的存储空间？
- Kafka实例的超高IO和高IO如何选择？
- 如何选择Kafka实例存储容量阈值策略？
- Kafka服务端支持版本是多少？
- Kafka实例的ZK地址是什么？
- 创建的Kafka实例是集群模式么？
- Kafka实例是否支持修改访问端口？
- Kafka实例的SSL证书有效期多长？
- 如何将Kafka实例中的数据同步到另一个Kafka实例中？
- Kafka实例的SASL_SSL开关如何修改？
- SASL认证机制如何修改？
- 如何修改安全协议？
- 修改企业项目，是否会导致Kafka重启？
- Kafka服务和ZK是部署在相同的虚拟机中，还是分开部署？
- Kafka包周期实例支持删除吗？
- Kafka支持哪些加密套件？
- 购买实例时选择的单AZ，怎样可以扩展为多AZ？
- Kafka是否支持跨AZ容灾？已经购买的实例在哪里查看是否为跨AZ？
- Kafka支持磁盘加密吗？
- Kafka实例创建后，能修改VPC和子网吗？
- 有没有Kafka Stream的案例？
- Kafka实例版本可以升级吗？
- 怎样重新绑定公网IP？
- 实例规格变更问题
-
连接问题
- 选择和配置安全组
- 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 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
- 实例管理
- Topic管理
- 消息管理
- 用户管理
- 消费组管理
- 流控管理
- 修改配置参数
- 调整资源配额
- 监控
- 云审计服务支持的关键操作
-
常见问题
-
实例问题
- 为什么可用区不能选择2个？
- 创建实例时为什么无法查看子网和安全组等信息？
- 如何选择Kafka实例的存储空间？
- Kafka实例的超高IO和高IO如何选择？
- 如何选择Kafka实例存储容量阈值策略？
- Kafka服务端支持版本是多少？
- Kafka实例的ZK地址是什么？
- 创建的Kafka实例是集群模式么？
- Kafka实例是否支持修改访问端口？
- Kafka实例的SSL证书有效期多长？
- 如何将Kafka实例中的数据同步到另一个Kafka实例中？
- Kafka实例的SASL_SSL开关如何修改？
- SASL认证机制如何修改？
- 修改企业项目，是否会导致Kafka重启？
- Kafka服务和ZK是部署在相同的虚拟机中，还是分开部署？
- Kafka支持哪些加密套件？
- 购买实例时选择的单AZ，怎样可以扩展为多AZ？
- Kafka是否支持跨AZ容灾？已经购买的实例在哪里查看是否为跨AZ？
- Kafka支持磁盘加密吗？
- Kafka扩容会影响业务吗？
- Kafka实例创建后，能修改VPC和子网吗？
- 有没有Kafka Stream的案例？
- Kafka实例版本可以升级吗？
- 实例版本在控制台和Kafka Manager上显示不一致？
- 怎样重新绑定公网IP？
-
连接问题
- 选择和配置安全组
- 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证书是否一样？
-
Topic和分区问题
- Kafka实例的Topic数量是否有限制？
- 为什么限制Topic的总分区数？
- Kafka支持增加减少分区数吗？
- Kafka实例创建Topic失败
- Kafka实例支持批量导入Topic功能么？或者是自动生成Topic功能？
- 为什么删除Topic不生效？删除后该Topic仍然存在
- Kafka实例是否支持查看单个Topic占用磁盘空间？
- Topic是否支持ACL权限配置？
- 消息被消费后，没有删除，导致Kafka存储空间占满？
- 如何扩总分区？
- 修改自动创建Topic的配置，会触发重启吗？
- 如何关闭自动创建Topic功能？
- Kafka可以删除消费组下不用的Topic吗？
- 消费者消费Topic失败，提示没有权限？
- 为什么实例中存在默认名为__trace和__consumer_offsets的Topic？
- 消费组问题
- 消息问题
-
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？
- 监控告警问题
-
实例问题
- 故障排除
- 修订记录
- API参考(阿布扎比区域)
-
用户指南(巴黎区域)
- 产品简介
- 快速入门
- 权限管理
- 准备实例依赖资源
- 创建实例
- 连接Kafka
- 实例管理
- Topic管理
- 消息管理
- 用户管理
- 消费组管理
- 流控管理
- 修改配置参数
- 调整资源配额
- 监控
- 云审计服务支持的关键操作
-
常见问题
-
实例问题
- 为什么可用区不能选择2个？
- 创建实例时为什么无法查看子网和安全组等信息？
- 如何选择Kafka实例的存储空间？
- Kafka实例的超高IO和高IO如何选择？
- 如何选择Kafka实例存储容量阈值策略？
- Kafka服务端支持版本是多少？
- Kafka实例的ZK地址是什么？
- 创建的Kafka实例是集群模式么？
- Kafka实例是否支持修改访问端口？
- Kafka实例的SSL证书有效期多长？
- 如何将Kafka实例中的数据同步到另一个Kafka实例中？
- Kafka实例的SASL_SSL开关如何修改？
- SASL认证机制如何修改？
- 修改企业项目，是否会导致Kafka重启？
- Kafka服务和ZK是部署在相同的虚拟机中，还是分开部署？
- Kafka支持哪些加密套件？
- 创建实例时选择的单AZ，怎样可以扩展为多AZ？
- Kafka是否支持跨AZ容灾？已经创建的实例在哪里查看是否为跨AZ？
- Kafka支持磁盘加密吗？
- Kafka实例创建后，能修改VPC和子网吗？
- 有没有Kafka Stream的案例？
- Kafka实例版本可以升级吗？
- 实例版本在控制台和Kafka Manager上显示不一致？
- 怎样重新绑定公网IP？
- 实例规格变更问题
-
连接问题
- 选择和配置安全组
- 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功能？
- 为什么删除Topic不生效？删除后该Topic仍然存在
- Kafka实例是否支持查看单个Topic占用磁盘空间？
- Topic是否支持ACL权限配置？
- 消息被消费后，没有删除，导致Kafka存储空间占满？
- 如何扩总分区？
- 修改自动创建Topic的配置，会触发重启吗？
- 如何关闭自动创建Topic功能？
- Kafka可以删除消费组下不用的Topic吗？
- 消费者消费Topic失败，提示没有权限？
- 为什么实例中存在默认名为__trace和__consumer_offsets的Topic？
- 消费组问题
- 消息问题
- Kafka Manager问题
- 监控告警问题
-
实例问题
- 故障排除
- 修订记录
- API参考(巴黎区域)
- 开发指南(巴黎区域)
-
用户指南（吉隆坡区域）
- 产品简介
- 快速入门
- Kafka业务使用流程
- 权限管理
- 购买Kafka实例
- 配置Topic
- 连接实例
- 管理消息
- 管理消费组
- 配置流控
- 管理实例
- 变更实例规格
- 迁移数据
- 申请扩大Kafka配额
- 查看监控指标与配置告警
- 查看Kafka审计日志
-
常见问题
-
实例问题
- 为什么可用区不能选择2个？
- 创建实例时为什么无法查看子网和安全组等信息？
- 如何选择Kafka实例的存储空间？
- Kafka实例的超高IO和高IO如何选择？
- 如何选择Kafka实例存储容量阈值策略？
- Kafka服务端支持版本是多少？
- Kafka实例的ZK地址是什么？
- 创建的Kafka实例是集群模式么？
- Kafka实例是否支持修改访问端口？
- Kafka实例的SSL证书有效期多长？
- 如何将Kafka实例中的数据同步到另一个Kafka实例中？
- Kafka实例的SASL_SSL开关如何修改？
- SASL认证机制如何修改？
- 修改企业项目，是否会导致Kafka重启？
- Kafka服务和ZK是部署在相同的虚拟机中，还是分开部署？
- Kafka支持哪些加密套件？
- 购买实例时选择的单AZ，怎样可以扩展为多AZ？
- Kafka是否支持跨AZ容灾？已经购买的实例在哪里查看是否为跨AZ？
- Kafka支持磁盘加密吗？
- Kafka实例创建后，能修改VPC和子网吗？
- 有没有Kafka Stream的案例？
- Kafka实例版本可以升级吗？
- 配置了“自动删除”策略，磁盘容量到达95%时，为什么没有自动删除最早的消息？
- 实例规格变更问题
-
连接问题
- 选择和配置安全组
- Kafka实例是否支持公网访问？
- Kafka实例的连接地址默认有多少个？
- 是否支持跨Region访问？
- Kafka实例是否支持跨VPC访问？
- Kafka实例是否支持不同的子网？
- Kafka是否支持Kerberos认证，如何开启认证？
- Kafka实例是否支持无密码访问？
- Kafka支持服务端认证客户端吗？
- 连接开启SASL_SSL的Kafka实例时，ssl truststore文件可以用PEM格式的吗？
- 下载的证书JKS和CRT有什么区别？
- Kafka支持哪个版本的TLS？
- Kafka实例连接数有限制吗？
- 客户端单IP连接的个数为多少？
- Kafka实例的内网连接地址可以修改吗？
- 不同实例中，使用的SSL证书是否一样？
- 为什么不建议使用Sarama客户端收发消息？
- Topic和分区问题
- 消费组问题
- 消息问题
-
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中仍可以看到此消费组？
- 监控告警问题
-
实例问题
- 故障排除
- 修订记录
- API参考（吉隆坡区域）
-
用户指南 (阿布扎比区域)
- 通用参考
链接复制成功！
认证鉴权
调用接口有如下两种认证方式，您可以选择其中一种进行认证鉴权。
- AK/SK认证：通过AK（Access Key ID）/SK（Secret Access Key）加密调用请求。推荐使用AK/SK认证，其安全性比Token认证要高。
- Token认证：通过Token认证调用请求。
AK/SK认证
说明：
AK/SK签名认证方式仅支持消息体大小12M以内，12M以上的请求请使用Token认证。
AK/SK认证就是使用AK/SK对请求进行签名，在请求时将签名信息添加到消息头，从而通过身份认证。
- AK(Access Key ID)：访问密钥ID。与私有访问密钥关联的唯一标识符；访问密钥ID和私有访问密钥一起使用，对请求进行加密签名。
- SK(Secret Access Key)：与访问密钥ID结合使用的密钥，对请求进行加密签名，可标识发送方，并防止请求被修改。
使用AK/SK认证时，您可以基于签名算法使用AK/SK对请求进行签名，也可以使用专门的签名SDK对请求进行签名。详细的签名方法和SDK使用方法请参见API签名指南。
须知：
须知：
签名SDK只提供签名功能，与服务提供的SDK不同，使用时请注意。
Token认证
说明：
Token的有效期为24小时，需要使用一个Token鉴权时，可以先缓存起来，避免频繁调用。
Token在计算机系统中代表令牌（临时）的意思，拥有Token就代表拥有某种权限。Token认证就是在调用API的时候将Token加到请求消息头，从而通过身份认证，获得操作API的权限。Token可通过调用获取用户Token接口获取。
云服务存在两种部署方式：项目级服务和全局级服务。其中：
- 项目级服务需要获取项目级别的Token，此时请求body中auth.scope的取值为project。
- 全局级服务需要获取全局级别的Token，此时请求body中auth.scope的取值为domain。
调用本服务API需要project级别的Token，即调用获取用户Token接口时，请求body中auth.scope的取值需要选择project，如下所示。
{
"auth": {
"identity": {
"methods": [
"password"
],
"password": {
"user": {
"name": "username", //IAM用户名
"password": $ADMIN_PASS, //IAM用户密码，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全
"domain": {
"name": "domainname" //IAM用户所属账号名
}
}
}
},
"scope": {
"project": {
"name": "xxxxxxxx" //项目名称
}
}
}
}获取Token后，再调用其他接口时，您需要在请求消息头中添加“X-Auth-Token”，其值即为Token。例如Token值为“ABCDEFG....”，则调用接口时将“X-Auth-Token: ABCDEFG....”加到请求消息头即可，如下所示。
POST https://iam.ap-southeast-1.myhuaweicloud.com/v3.0/OS-USER/users Content-Type: application/json X-Auth-Token: ABCDEFG....
父主题： 如何调用API
