1// Introduced for KIP-700, DescribeClusterRequest is effectively an "admin"
2// type metadata request for information that producers or consumers do not
3// need to care about.
4DescribeClusterRequest => key 60, max version 0, flexible v0+
5 // Whether to include cluster authorized operations. This requires DESCRIBE
6 // on CLUSTER.
7 IncludeClusterAuthorizedOperations: bool
8
9// DescribeClusterResponse is a response to a DescribeClusterRequest.
10DescribeClusterResponse =>
11 ThrottleMillis
12 // The top level response error code.
13 ErrorCode: int16
14 // The top level error message, if any.
15 ErrorMessage: nullable-string
16 // The cluster ID that responding broker belongs to.
17 ClusterID: string
18 // The ID of the controller broker.
19 ControllerID: int32(-1)
20 // Brokers is a set of alive Kafka brokers (this mirrors MetadataResponse.Brokers).
21 Brokers: [=>]
22 // NodeID is the node ID of a Kafka broker.
23 NodeID: int32
24 // Host is the hostname of a Kafka broker.
25 Host: string
26 // Port is the port of a Kafka broker.
27 Port: int32
28 // Rack is the rack this Kafka broker is in, if any.
29 Rack: nullable-string
30 // 32-bit bitfield to represent authorized operations for this cluster.
31 ClusterAuthorizedOperations: int32(-2147483648)
View as plain text