分布式消息服务Kafka版
分布式消息服务Kafka版
- 最新动态
- 功能总览
- 服务公告
- 产品介绍
- 计费说明
- 快速入门
- 用户指南
- 最佳实践
- 开发指南
- API参考
- 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实例的连接地址默认有多少个？
- 是否支持跨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体验版使用说明
-
实例问题
- 故障排除
- 视频帮助
- 文档下载
- 通用参考
链接复制成功！
查询消费组信息
URI
GET /v1.0/{project_id}/instances/{instance_id}/manage/groups/{group}
参数说明如下表所示。
|
参数 |
类型 |
必选 |
说明 |
|---|---|---|---|
|
project_id |
String |
是 |
项目ID。 |
|
instance_id |
String |
是 |
实例ID。 |
|
group |
String |
是 |
消费组名称。 |
请求消息
请求参数
无
请求示例
无
响应消息
响应参数
参数说明见表2。
|
参数 |
类型 |
说明 |
|---|---|---|
|
group_id |
String |
消费组名称。 |
|
state |
String |
消费组状态。包含以下状态：
|
|
coordinator_id |
Integer |
协调器编号 |
|
members |
Array of object members |
消费者列表。参数参见表3。 |
|
group_message_offsets |
Array of group_offsets |
消费进度。参数参见表4。 |
|
assignment_strategy |
String |
分区分配策略。 |
|
参数 |
类型 |
说明 |
|---|---|---|
|
host |
String |
消费组consumer地址。 |
|
assignment |
Array of object assignment |
consumer分配到的分区信息。参数请参见表5。 |
|
member_id |
String |
消费组consumer的ID。 |
|
client_id |
String |
客户端ID。 |
|
参数 |
类型 |
说明 |
|---|---|---|
|
topic |
String |
topic名称。 |
|
partition |
Integer |
分区编号。 |
|
message_current_offset |
Long |
当前消费进度。 |
|
message_log_end_offset |
Long |
最大消息位置（LEO）。 |
|
lag |
Long |
剩余可消费消息数，即消息堆积数。 |
响应示例
{
"group": {
"members": [
{
"host": "/172.31.1.102",
"assignment": [
{
"topic": "test",
"partitions": [
0,
1,
2
]
}
],
"member_id": "consumer-1-6b8ee551-d499-47d4-9beb-ba1527496785",
"client_id": "consumer-1"
}
],
"state": "STABLE",
"group_id": "test-consumer-group",
"coordinator_id": 2,
"group_message_offsets": [
{
"partition": 0,
"lag": 31396,
"topic": "test",
"message_current_offset": 935,
"message_log_end_offset": 32331
},
{
"partition": 0,
"lag": 0,
"topic": "aaaa",
"message_current_offset": 0,
"message_log_end_offset ": 0
},
{
"partition": 1,
"lag": 31279,
"topic": "test",
"message_current_offset": 1058,
"message_log_end_offset ": 32337
},
{
"partition": 1,
"lag": 0,
"topic": "aaaa",
"message_current_offset": 0,
"message_log_end_offset": 0
},
{
"partition": 2,
"lag": 31603,
"topic": "test",
"message_current_offset": 739,
"message_log_end_offset": 32342
}
],
"assignment_strategy": "range"
}
}
父主题： 实例使用类接口
