分布式消息服务KAFKA版-查询Kafka实例Topic详细信息:响应消息

时间:2024-01-24 16:40:32

响应消息

响应参数

参数说明见表2

表2 响应参数说明

参数

类型

说明

topic

String

topic名称。

partitions

Array of object partitions

分区列表。参数查看表3

group_subscribed

Array of String

订阅该topic的消费组名称列表。

表3 partitions参数说明

参数

类型

说明

partition

Integer

分区ID。

leader

Integer

leader副本所在节点的id。

leo

long

分区leader副本的LEO(Log End Offset)。

hw

long

分区高水位(HW,High Watermark)。

lso

long

分区leader副本的LSO(Log Start Offset)。

last_update_timestamp

long

分区上次写入消息的时间。

replicas

Array of object replicas

副本列表。参数查看表4

表4 replicas参数说明

参数

类型

说明

broker

Integer

副本所在的节点ID。

leader

Boolean

该副本是否为leader。

in_sync

Boolean

该副本是否在ISR副本中。

size

Long

该副本当前日志大小。

lag

Long

该副本当前落后hw的消息数。

响应示例

{
    "topic": "test",
    "partitions": [
        {
            "partition": 0,
            "leader": 2,
            "replicas": [
                {
                    "broker": 2,
                    "leader": true,
                    "in_sync": true,
                    "size": 123971146,
                    "lag": 0
                },
                {
                    "broker": 1,
                    "leader": false,
                    "in_sync": true,
                    "size": 123971146,
                    "lag": 0
                },
                {
                    "broker": 0,
                    "leader": false,
                    "in_sync": true,
                    "size": 123971146,
                    "lag": 0
                }
            ],
            "lso": 0,
            "leo": 13598,
            "hw": 13598,
            "last_update_timestamp": 1571477180985
        },
        {
            "partition": 2,
            "leader": 1,
            "replicas": [
                {
                    "broker": 1,
                    "leader": true,
                    "in_sync": true,
                    "size": 123889531,
                    "lag": 0
                },
                {
                    "broker": 0,
                    "leader": false,
                    "in_sync": true,
                    "size": 123889531,
                    "lag": 0
                },
                {
                    "broker": 2,
                    "leader": false,
                    "in_sync": true,
                    "size": 123889531,
                    "lag": 0
                }
            ],
            "lso": 0,
            "leo": 13601,
            "hw": 13601,
            "last_update_timestamp": 1571477077146
        },
        {
            "partition": 1,
            "leader": 0,
            "replicas": [
                {
                    "broker": 0,
                    "leader": true,
                    "in_sync": true,
                    "size": 127245604,
                    "lag": 0
                },
                {
                    "broker": 2,
                    "leader": false,
                    "in_sync": true,
                    "size": 127245604,
                    "lag": 0
                },
                {
                    "broker": 1,
                    "leader": false,
                    "in_sync": true,
                    "size": 127245604,
                    "lag": 0
                }
            ],
            "lso": 0,
            "leo": 13599,
            "hw": 13599,
            "last_update_timestamp": 1571477172959
        }
    ],
    "group_subscribed": [
        "test-consumer-group"
    ]
}
support.huaweicloud.com/api-kafka/kafka-api-191209011.html