conduktor.io ↗

Kafka DescribeCluster Changelog — Protocol Version History

What is DescribeCluster?

Returns the authoritative list of brokers, the active controller, and cluster-level authorized operations via AdminClient.describeCluster(). Unlike Metadata, this can filter by endpoint type (broker vs controller), which matters in KRaft mode where controllers may not be brokers.

VersionKafkaChanges
DescribeClusterRequest
v02.8
+ IncludeClusterAuthorizedOperations bool
~ Flexible encoding enabled FLEXIBLE
v13.7
+ EndpointType int8
adds EndpointType for KIP-919 support.
v24.0
+ IncludeFencedBrokers bool
adds IncludeFencedBrokers for KIP-1073 support.
DescribeClusterResponse
v02.8
+ ThrottleTimeMs int32
+ ErrorCode int16
+ ErrorMessage string
+ ClusterId string
+ ControllerId int32
+ Brokers []DescribeClusterBroker
+ BrokerId int32
+ Host string
+ Port int32
+ Rack string
+ ClusterAuthorizedOperations int32
~ Flexible encoding enabled FLEXIBLE
v13.7
+ EndpointType int8
adds the EndpointType field, and makes MISMATCHED_ENDPOINT_TYPE and UNSUPPORTED_ENDPOINT_TYPE valid top-level response error codes.
v24.0
+ IsFenced bool
adds IsFenced field to Brokers for KIP-1073 support.