View Source KlifeProtocol.Messages.BeginQuorumEpoch (Klife Protocol v0.9.0)
Kafka protocol BeginQuorumEpoch message
Request versions summary:
- Version 1 adds flexible versions, voter key and leader endpoints (KIP-853)
Response versions summary:
- Version 1 adds flexible versions and leader endpoint (KIP-853)
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+)
topics: The topic data. ([]TopicData | versions 0+)
topic_name: The topic name. (string | versions 0+)
partitions: The partition data. ([]PartitionData | versions 0+)
partition_index: The partition index. (int32 | versions 0+)
error_code: The error code for this partition. (int16 | versions 0+)
leader_id: The ID of the current leader or -1 if the leader is unknown. (int32 | versions 0+)
leader_epoch: The latest known leader epoch. (int32 | versions 0+)
node_endpoints: Endpoints for all leaders enumerated in PartitionData. ([]NodeEndpoint | versions 1+)
node_id: The ID of the associated node. (int32 | versions 1+)
host: The node's hostname. (string | versions 1+)
port: The node's port. (uint16 | versions 1+)
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:
cluster_id: The cluster id. (string | versions 0+)
voter_id: The replica id of the voter receiving the request. (int32 | versions 1+)
topics: The topics. ([]TopicData | versions 0+)
topic_name: The topic name. (string | versions 0+)
partitions: The partitions. ([]PartitionData | versions 0+)
partition_index: The partition index. (int32 | versions 0+)
voter_directory_id: The directory id of the receiving replica. (uuid | versions 1+)
leader_id: The ID of the newly elected leader. (int32 | versions 0+)
leader_epoch: The epoch of the newly elected leader. (int32 | versions 0+)
leader_endpoints: Endpoints for the leader. ([]LeaderEndpoint | versions 1+)
name: The name of the endpoint. (string | versions 1+)
host: The node's hostname. (string | versions 1+)
port: The node's port. (uint16 | versions 1+)