Trait kafka_protocol::protocol::HeaderVersion

pub trait HeaderVersion {
    fn header_version(version: i16) -> i16;
}

Every message has a set of versions valid for a given header version.

Required Methods

fn header_version(version: i16) -> i16

Maps a header version to a given version for a particular API message.

Implementors

impl HeaderVersion for AddOffsetsToTxnRequest

impl HeaderVersion for AddOffsetsToTxnResponse

impl HeaderVersion for AddPartitionsToTxnRequest

impl HeaderVersion for AddPartitionsToTxnResponse

impl HeaderVersion for AllocateProducerIdsRequest

impl HeaderVersion for AllocateProducerIdsResponse

impl HeaderVersion for AlterClientQuotasRequest

impl HeaderVersion for AlterClientQuotasResponse

impl HeaderVersion for AlterConfigsRequest

impl HeaderVersion for AlterConfigsResponse

impl HeaderVersion for AlterPartitionReassignmentsRequest

impl HeaderVersion for AlterPartitionReassignmentsResponse

impl HeaderVersion for AlterPartitionRequest

impl HeaderVersion for AlterPartitionResponse

impl HeaderVersion for AlterReplicaLogDirsRequest

impl HeaderVersion for AlterReplicaLogDirsResponse

impl HeaderVersion for AlterUserScramCredentialsRequest

impl HeaderVersion for AlterUserScramCredentialsResponse

impl HeaderVersion for ApiVersionsRequest

impl HeaderVersion for ApiVersionsResponse

impl HeaderVersion for BeginQuorumEpochRequest

impl HeaderVersion for BeginQuorumEpochResponse

impl HeaderVersion for BrokerHeartbeatRequest

impl HeaderVersion for BrokerHeartbeatResponse

impl HeaderVersion for BrokerRegistrationRequest

impl HeaderVersion for BrokerRegistrationResponse

impl HeaderVersion for ControlledShutdownRequest

impl HeaderVersion for ControlledShutdownResponse

impl HeaderVersion for CreateAclsRequest

impl HeaderVersion for CreateAclsResponse

impl HeaderVersion for CreateDelegationTokenRequest

impl HeaderVersion for CreateDelegationTokenResponse

impl HeaderVersion for CreatePartitionsRequest

impl HeaderVersion for CreatePartitionsResponse

impl HeaderVersion for CreateTopicsRequest

impl HeaderVersion for CreateTopicsResponse

impl HeaderVersion for DeleteAclsRequest

impl HeaderVersion for DeleteAclsResponse

impl HeaderVersion for DeleteGroupsRequest

impl HeaderVersion for DeleteGroupsResponse

impl HeaderVersion for DeleteRecordsRequest

impl HeaderVersion for DeleteRecordsResponse

impl HeaderVersion for DeleteTopicsRequest

impl HeaderVersion for DeleteTopicsResponse

impl HeaderVersion for DescribeAclsRequest

impl HeaderVersion for DescribeAclsResponse

impl HeaderVersion for DescribeClientQuotasRequest

impl HeaderVersion for DescribeClientQuotasResponse

impl HeaderVersion for DescribeClusterRequest

impl HeaderVersion for DescribeClusterResponse

impl HeaderVersion for DescribeConfigsRequest

impl HeaderVersion for DescribeConfigsResponse

impl HeaderVersion for DescribeDelegationTokenRequest

impl HeaderVersion for DescribeDelegationTokenResponse

impl HeaderVersion for DescribeGroupsRequest

impl HeaderVersion for DescribeGroupsResponse

impl HeaderVersion for DescribeLogDirsRequest

impl HeaderVersion for DescribeLogDirsResponse

impl HeaderVersion for DescribeProducersRequest

impl HeaderVersion for DescribeProducersResponse

impl HeaderVersion for DescribeQuorumRequest

impl HeaderVersion for DescribeQuorumResponse

impl HeaderVersion for DescribeTransactionsRequest

impl HeaderVersion for DescribeTransactionsResponse

impl HeaderVersion for DescribeUserScramCredentialsRequest

impl HeaderVersion for DescribeUserScramCredentialsResponse

impl HeaderVersion for ElectLeadersRequest

impl HeaderVersion for ElectLeadersResponse

impl HeaderVersion for EndQuorumEpochRequest

impl HeaderVersion for EndQuorumEpochResponse

impl HeaderVersion for EndTxnRequest

impl HeaderVersion for EndTxnResponse

impl HeaderVersion for EnvelopeRequest

impl HeaderVersion for EnvelopeResponse

impl HeaderVersion for ExpireDelegationTokenRequest

impl HeaderVersion for ExpireDelegationTokenResponse

impl HeaderVersion for FetchRequest

impl HeaderVersion for FetchResponse

impl HeaderVersion for FetchSnapshotRequest

impl HeaderVersion for FetchSnapshotResponse

impl HeaderVersion for FindCoordinatorRequest

impl HeaderVersion for FindCoordinatorResponse

impl HeaderVersion for HeartbeatRequest

impl HeaderVersion for HeartbeatResponse

impl HeaderVersion for IncrementalAlterConfigsRequest

impl HeaderVersion for IncrementalAlterConfigsResponse

impl HeaderVersion for InitProducerIdRequest

impl HeaderVersion for InitProducerIdResponse

impl HeaderVersion for JoinGroupRequest

impl HeaderVersion for JoinGroupResponse

impl HeaderVersion for LeaderAndIsrRequest

impl HeaderVersion for LeaderAndIsrResponse

impl HeaderVersion for LeaveGroupRequest

impl HeaderVersion for LeaveGroupResponse

impl HeaderVersion for ListGroupsRequest

impl HeaderVersion for ListGroupsResponse

impl HeaderVersion for ListOffsetsRequest

impl HeaderVersion for ListOffsetsResponse

impl HeaderVersion for ListPartitionReassignmentsRequest

impl HeaderVersion for ListPartitionReassignmentsResponse

impl HeaderVersion for ListTransactionsRequest

impl HeaderVersion for ListTransactionsResponse

impl HeaderVersion for MetadataRequest

impl HeaderVersion for MetadataResponse

impl HeaderVersion for OffsetCommitRequest

impl HeaderVersion for OffsetCommitResponse

impl HeaderVersion for OffsetDeleteRequest

impl HeaderVersion for OffsetDeleteResponse

impl HeaderVersion for OffsetFetchRequest

impl HeaderVersion for OffsetFetchResponse

impl HeaderVersion for OffsetForLeaderEpochRequest

impl HeaderVersion for OffsetForLeaderEpochResponse

impl HeaderVersion for ProduceRequest

impl HeaderVersion for ProduceResponse

impl HeaderVersion for RenewDelegationTokenRequest

impl HeaderVersion for RenewDelegationTokenResponse

impl HeaderVersion for SaslAuthenticateRequest

impl HeaderVersion for SaslAuthenticateResponse

impl HeaderVersion for SaslHandshakeRequest

impl HeaderVersion for SaslHandshakeResponse

impl HeaderVersion for StopReplicaRequest

impl HeaderVersion for StopReplicaResponse

impl HeaderVersion for SyncGroupRequest

impl HeaderVersion for SyncGroupResponse

impl HeaderVersion for TxnOffsetCommitRequest

impl HeaderVersion for TxnOffsetCommitResponse

impl HeaderVersion for UnregisterBrokerRequest

impl HeaderVersion for UnregisterBrokerResponse

impl HeaderVersion for UpdateFeaturesRequest

impl HeaderVersion for UpdateFeaturesResponse

impl HeaderVersion for UpdateMetadataRequest

impl HeaderVersion for UpdateMetadataResponse

impl HeaderVersion for VoteRequest

impl HeaderVersion for VoteResponse

impl HeaderVersion for WriteTxnMarkersRequest

impl HeaderVersion for WriteTxnMarkersResponse