conduktor.io ↗

Kafka ControllerRegistration Changelog — Protocol Version History

What is ControllerRegistration?

Dedicated KRaft controller nodes (non-broker controllers) send this to register with the active controller on startup. This is the controller equivalent of BrokerRegistration, specific to deployments where controller nodes don't host topic partitions.

VersionKafkaChanges
ControllerRegistrationRequest
v03.7
+ ControllerId int32
+ IncarnationId uuid
+ ZkMigrationReady bool
+ Listeners []Listener
+ Name string
+ Host string
+ Port uint16
+ SecurityProtocol int16
+ Features []Feature
+ Name string
+ MinSupportedVersion int16
+ MaxSupportedVersion int16
~ Flexible encoding enabled FLEXIBLE
ControllerRegistrationResponse
v03.7
+ ThrottleTimeMs int32
+ ErrorCode int16
+ ErrorMessage string
~ Flexible encoding enabled FLEXIBLE