分布式消息服务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"
    ]
}

上一篇：分布式消息服务KAFKA版-修改Kafka实例Topic:请求示例

下一篇：分布式消息服务KAFKA版-Kafka实例查询Topic:响应参数