Querying Topic Details
Function
This API is used to query topic details of a Kafka instance.
Debugging
You can use API Explorer to debug this API.
URI
GET /v2/{project_id}/instances/{instance_id}/management/topics/{topic}
| Parameter | Mandatory | Type | Description |
|---|---|---|---|
| project_id | Yes | String | Project ID. |
| instance_id | Yes | String | Instance ID. |
| topic | Yes | String | Topic name. |
Request Parameters
None
Response Parameters
Status code: 200
| Parameter | Type | Description |
|---|---|---|
| topic | String | Topic name. |
| partitions | Array of partitions objects | Partition list. |
| group_subscribed | Array of strings | List of consumer groups that subscribe to the topic. |
| Parameter | Type | Description |
|---|---|---|
| partition | Integer | Partition ID. |
| leader | Integer | ID of the broker where the leader replica resides. |
| leo | Integer | LEO of the partition leader replica. |
| hw | Integer | High watermark (HW) of the partition. |
| lso | Integer | Log start offset (LSO) of the partition leader replica. |
| last_update_timestamp | Long | Time when the last message was written to the partition. The value is a Unix timestamp. Unit: ms. |
| replicas | Array of replicas objects | Replica list. |
| Parameter | Type | Description |
|---|---|---|
| broker | Integer | ID of the broker where the replica resides. |
| leader | Boolean | Whether the replica is the leader. |
| in_sync | Boolean | Whether the replica is in the ISR. |
| size | Integer | Current log size of the replica. Unit: byte. |
| lag | Integer | Number of messages that lag behind the high watermark in the replica. |
Example Requests
GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/topics/{topic} Example Responses
Status code: 200
The query is successful.
{
"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" ]
} Status Codes
| Status Code | Description |
|---|---|
| 200 | The query is successful. |
Error Codes
See Error Codes.
Last Article: Batch Deleting Topics of a Kafka Instance
Next Article: User Management
Did this article solve your problem?
Thank you for your score!Your feedback would help us improve the website.