View Source KlifeProtocol.Messages.ControlledShutdown (Klife Protocol v0.5.0)
Kafka protocol ControlledShutdown message
Request versions summary:
- Version 0 of ControlledShutdownRequest has a non-standard request header which does not include clientId. Version 1 and later use the standard request header.
- Version 1 is the same as version 0.
- Version 2 adds BrokerEpoch.
Response versions summary:
- Versions 1 and 2 are the same as version 0.
Link to this section Summary
Functions
Returns the message api key number.
Receive a binary in the kafka wire format and deserialize it into a map.
Returns the current max supported version of this message.
Returns the current min supported version of this message.
Receives a map and serialize it to kafka wire format of the given version.
Link to this section Functions
Returns the message api key number.
Receive a binary in the kafka wire format and deserialize it into a map.
Response content fields:
error_code: The top-level error code. (int16 | versions 0+)
remaining_partitions: The partitions that the broker still leads. ([]RemainingPartition | versions 0+)
topic_name: The name of the topic. (string | versions 0+)
partition_index: The index of the partition. (int32 | versions 0+)
Returns the current max supported version of this message.
Returns the current min supported version of this message.
Receives a map and serialize it to kafka wire format of the given version.
Input content fields:
broker_id: The id of the broker for which controlled shutdown has been requested. (int32 | versions 0+)
broker_epoch: The broker epoch. (int64 | versions 2+)