- 最新动态
- 功能总览
- 服务公告
- 产品介绍
- 计费说明
- 快速入门
- 用户指南
- 最佳实践
- 开发指南
- 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参考(吉隆坡区域)
-
用户指南 (阿布扎比区域)
- 通用参考
链接复制成功!
查询指定实例
功能介绍
查询指定实例的详细信息。
请求消息
请求参数
无。
请求示例
GET https://{dms_endpoint}/v1.0/{project_id}/instances/{instance_id}
响应消息
响应参数
参数说明见表2。
参数 |
类型 |
说明 |
---|---|---|
name |
String |
实例名称。 |
engine |
String |
消息引擎。 |
engine_version |
String |
消息引擎版本。 |
specification |
String |
实例规格。 |
storage_space |
Integer |
消息存储空间,单位:GB。 |
partition_num |
String |
Kafka实例的总分区数。 |
used_storage_space |
Integer |
已使用的消息存储空间,单位:GB。 |
connect_address |
String |
实例连接IP地址。 |
port |
Integer |
实例连接端口。 |
status |
String |
实例的状态。详细状态说明见实例状态说明。 |
instance_id |
String |
实例ID。 |
resource_spec_code |
String |
资源规格标识。
|
type |
String |
实例类型:集群,cluster |
charging_mode |
Integer |
付费模式,1表示按需计费,0表示包年/包月计费。 |
vpc_id |
String |
VPC ID。 |
vpc_name |
String |
VPC的名称。 |
created_at |
String |
完成创建时间。格式为时间戳,指从格林威治时间 1970年01月01日00时00分00秒起至指定时间的偏差总毫秒数。 |
product_id |
String |
产品标识。 |
security_group_id |
String |
安全组ID。 |
security_group_name |
String |
租户安全组名称。 |
subnet_id |
String |
子网ID。 |
subnet_name |
String |
子网名称。 |
subnet_cidr |
String |
子网网段。 |
available_zones |
Array |
实例节点所在的可用区,返回“可用区ID”。 |
user_id |
String |
用户id。 |
user_name |
String |
用户名。 |
access_user |
String |
实例的用户名。 |
order_id |
String |
订单ID。 |
maintain_begin |
String |
维护时间窗开始时间,格式为HH:mm:ss。 |
maintain_end |
String |
维护时间窗结束时间,格式为HH:mm:ss。 |
enable_publicip |
Boolean |
实例是否开启公网访问功能。
|
management_connect_address |
String |
Kafka实例的Kafka Manager连接地址。 |
ssl_enable |
Boolean |
是否开启安全认证。
|
enterprise_project_id |
String |
企业项目ID。 |
is_logical_volume |
Boolean |
实例扩容时用于区分老实例与新实例。
|
extend_times |
Integer |
实例扩容磁盘次数,如果超过20次则无法扩容磁盘。 |
enable_auto_topic |
Boolean |
是否打开Kafka自动创建Topic功能。
|
total_storage_space |
Integer |
总共消息存储空间,单位:GB。 |
storage_resource_id |
String |
存储资源ID。 |
storage_spec_code |
String |
IO规格。 |
service_type |
String |
服务类型。 |
storage_type |
String |
存储类型。 |
retention_policy |
String |
消息老化策略。 |
kafka_public_status |
String |
Kafka公网开启状态。 |
public_bandwidth |
Integer |
公网带宽。 |
public_connect_address |
String |
实例公网连接IP地址。当实例开启了公网访问,实例才包含该参数。 |
kafka_manager_user |
String |
登录Kafka Manager的用户名。 |
enable_log_collection |
Boolean |
是否开启消息收集功能。 |
cross_vpc_info |
String |
跨VPC访问信息。 |
ipv6_enable |
Boolean |
是否开启ipv6。 |
ipv6_connect_addresses |
Array of strings |
IPv6的连接地址。 |
rest_enable |
Boolean |
是否开启Kafka rest功能。 |
rest_connect_address |
String |
Kafka rest连接地址。 |
message_query_inst_enable |
Boolean |
是否开启消息查询功能。 |
vpc_client_plain |
Boolean |
是否开启VPC明文访问。 |
support_features |
String |
Kafka实例支持的特性功能。 |
trace_enable |
Boolean |
是否开启消息轨迹功能。 |
pod_connect_address |
String |
租户侧连接地址。 |
disk_encrypted |
Boolean |
是否开启磁盘加密。
|
kafka_private_connect_address |
String |
Kafka实例私有连接地址。 |
ces_version |
String |
云监控版本。 |
tags |
Array<Object> |
标签列表。 |
参数 |
参数类型 |
描述 |
---|---|---|
key |
String |
标签的键。 |
value |
String |
标签的值。 |
响应示例
{
"name": "kafka-l00230526",
"engine": "kafka",
"port": 9092,
"status": "RUNNING",
"type": "cluster",
"specification": "100MB",
"engine_version": "XXX",
"connect_address": "192.168.1.116,192.168.1.152,192.168.1.78",
"connect_dn": "",
"instance_id": "ef84dd5f-3ece-4336-8c99-987defd62e3a",
"resource_spec_code": "dms.instance.kafka.cluster.c3.mini",
"charging_mode": 1,
"vpc_id": "2477879f-aebf-496f-a08a-67812885ce9b",
"vpc_name": "vpc-y00502467",
"created_at": "1568797295209",
"product_id": "00300-30308-0--0",
"security_group_id": "008a08e2-10cc-4d9b-90ab-3f3b8f6c3333",
"security_group_name": "z00417080-cce-node-na7j",
"subnet_id": "5ca08fb7-7522-4d95-9fa5-ff6b3592a29d",
"subnet_name": "subnet-cyd-6102",
"subnet_cidr": "192.168.1.0/24",
"available_zones": [
"ae04cf9d61544df3806a3feeb401b204"
],
"user_id": "2b4af4428ec840dfa1f0f1a32e965567",
"user_name": "laiyh",
"kafka_manager_user": "root",
"maintain_begin": "22:00:00",
"maintain_end": "02:00:00",
"storage_space": 492,
"total_storage_space": 600,
"used_storage_space": 25,
"partition_num": "300",
"ssl_enable": false,
"management_connect_address": "https://192.168.1.116:9999",
"storage_resource_id": "81982562-ce8b-490a-95fa-2b225c292271",
"storage_spec_code": "dms.physical.storage.ultra",
"service_type": "advanced",
"storage_type": "hec",
"enterprise_project_id": "0",
"is_logical_volume": true,
"extend_times": 0,
"retention_policy": "produce_reject",
"ipv6_enable": false,
"ipv6_connect_addresses": [],
"connector_enable": false,
"connector_id": "",
"rest_enable": false,
"rest_connect_address": "",
"message_query_inst_enable": true,
"vpc_client_plain": false,
"support_features": "feature.physerver.kafka.topic.accesspolicy,message_trace_enable,features.pod.token.access,feature.physerver.kafka.pulbic.dynamic,feature.physerver.kafka.user.manager",
"trace_enable": false,
"agent_enable": false,
"pod_connect_address": "100.113.16.105:9100,100.113.5.197:9100,100.113.15.231:9100",
"disk_encrypted": false,
"enable_auto_topic": true
}