Querying Kafka Cluster Metadata
Function
This API is used to query Kafka cluster metadata.
URI
GET /v2/{project_id}/instances/{instance_id}/management/cluster
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
project_id |
Yes |
String |
Project ID. For details about how to obtain it, see Obtaining a Project ID. |
instance_id |
Yes |
String |
Instance ID. |
Request Parameters
None
Response Parameters
Status code: 200
Parameter |
Type |
Description |
---|---|---|
cluster |
cluster object |
Cluster basic information. |
Parameter |
Type |
Description |
---|---|---|
controller |
String |
Controller ID. |
brokers |
Array of brokers objects |
Broker list. |
topics_count |
Integer |
Number of topics. |
partitions_count |
Integer |
Number of partitions. |
online_partitions_count |
Integer |
Number of online partitions. |
replicas_count |
Integer |
Number of replicas. |
isr_replicas_count |
Integer |
Total number of in-sync replicas (ISRs). |
consumers_count |
Integer |
Number of consumer groups. |
Parameter |
Type |
Description |
---|---|---|
host |
String |
Broker IP address. |
port |
Integer |
Port number. |
broker_id |
String |
Broker ID. |
is_controller |
Boolean |
Whether the broker is a controller. |
version |
String |
Server version. |
register_time |
Long |
Broker registration time, which is a Unix timestamp. |
is_health |
Boolean |
Whether Kafka brokers can be connected. |
Example Requests
GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/cluster
Example Responses
Status code: 200
Kafka cluster metadata is queried successfully.
{ "cluster" : { "controller" : "2", "brokers" : [ { "host" : "192.168.0.159", "port" : 9093, "broker_id" : "0", "is_controller" : false, "version" : "1.1.0", "register_time" : 1588754647872, "is_health" : true }, { "host" : "192.168.0.48", "port" : 9093, "broker_id" : "1", "is_controller" : false, "version" : "1.1.0", "register_time" : 1588754647653, "is_health" : true }, { "host" : "192.168.0.212", "port" : 9093, "broker_id" : "2", "is_controller" : true, "version" : "1.1.0", "register_time" : 1588754647284, "is_health" : true } ], "topics_count" : 3, "partitions_count" : 9, "online_partitions_count" : 9, "replicas_count" : 27, "isr_replicas_count" : 27, "consumers_count" : 0 } }
Status Codes
Status Code |
Description |
---|---|
200 |
Kafka cluster metadata is queried successfully. |
Error Codes
See Error Codes.
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot