Trait kafka_protocol::protocol::Decodable

source · [−]

pub trait Decodable: Sized {
    fn decode<B: ByteBuf>(
        buf: &mut B, 
        version: i16
    ) -> Result<Self, DecodeError>;
}

Expand description

A decodable message.

Required methods

source

fn decode<B: ByteBuf>(buf: &mut B, version: i16) -> Result<Self, DecodeError>

Decode the message from the provided buffer and version.

Implementors

source

impl Decodable for kafka_protocol::messages::alter_client_quotas_request::EntityData

source

impl Decodable for kafka_protocol::messages::alter_client_quotas_request::EntryData

source

impl Decodable for OpData

source

impl Decodable for AlterClientQuotasResponse

source

impl Decodable for kafka_protocol::messages::alter_client_quotas_response::EntityData

source

impl Decodable for kafka_protocol::messages::alter_client_quotas_response::EntryData

source

impl Decodable for AlterConfigsRequest

source

impl Decodable for kafka_protocol::messages::alter_configs_request::AlterConfigsResource

source

impl Decodable for kafka_protocol::messages::alter_configs_response::AlterConfigsResourceResponse

source

impl Decodable for AlterConfigsResponse

source

impl Decodable for AlterIsrRequest

source

impl Decodable for kafka_protocol::messages::alter_isr_request::PartitionData

source

impl Decodable for kafka_protocol::messages::alter_isr_request::TopicData

source

impl Decodable for AlterIsrResponse

source

impl Decodable for kafka_protocol::messages::alter_isr_response::PartitionData

source

impl Decodable for kafka_protocol::messages::alter_isr_response::TopicData

source

impl Decodable for AlterPartitionReassignmentsRequest

source

impl Decodable for ReassignablePartition

source

impl Decodable for ReassignableTopic

source

impl Decodable for AlterPartitionReassignmentsResponse

source

impl Decodable for ReassignablePartitionResponse

source

impl Decodable for ReassignableTopicResponse

source

impl Decodable for AlterReplicaLogDirsRequest

source

impl Decodable for AlterReplicaLogDirPartitionResult

source

impl Decodable for AlterReplicaLogDirTopicResult

source

impl Decodable for AlterReplicaLogDirsResponse

source

impl Decodable for AlterUserScramCredentialsRequest

source

impl Decodable for ScramCredentialDeletion

source

impl Decodable for ScramCredentialUpsertion

source

impl Decodable for AlterUserScramCredentialsResponse

source

impl Decodable for AlterUserScramCredentialsResult

source

impl Decodable for ApiVersionsRequest

source

impl Decodable for ApiVersionsResponse

source

impl Decodable for BeginQuorumEpochRequest

source

impl Decodable for kafka_protocol::messages::begin_quorum_epoch_request::PartitionData

source

impl Decodable for kafka_protocol::messages::begin_quorum_epoch_request::TopicData

source

impl Decodable for BeginQuorumEpochResponse

source

impl Decodable for kafka_protocol::messages::begin_quorum_epoch_response::PartitionData

source

impl Decodable for kafka_protocol::messages::begin_quorum_epoch_response::TopicData

source

impl Decodable for BrokerHeartbeatRequest

source

impl Decodable for BrokerHeartbeatResponse

source

impl Decodable for BrokerRegistrationRequest

source

impl Decodable for BrokerRegistrationResponse

source

impl Decodable for ConsumerProtocolAssignment

source

impl Decodable for ConsumerProtocolSubscription

source

impl Decodable for ControlledShutdownRequest

source

impl Decodable for ControlledShutdownResponse

source

impl Decodable for RemainingPartition

source

impl Decodable for AclCreation

source

impl Decodable for CreateAclsRequest

source

impl Decodable for AclCreationResult

source

impl Decodable for CreateAclsResponse

source

impl Decodable for CreatableRenewers

source

impl Decodable for CreateDelegationTokenRequest

source

impl Decodable for CreateDelegationTokenResponse

source

impl Decodable for CreatePartitionsAssignment

source

impl Decodable for CreatePartitionsRequest

source

impl Decodable for CreatePartitionsResponse

source

impl Decodable for CreatePartitionsTopicResult

source

impl Decodable for CreateTopicsRequest

source

impl Decodable for CreatableTopicConfigs

source

impl Decodable for CreateTopicsResponse

source

impl Decodable for DefaultPrincipalData

source

impl Decodable for DeleteAclsFilter

source

impl Decodable for DeleteAclsRequest

source

impl Decodable for DeleteAclsFilterResult

source

impl Decodable for DeleteAclsMatchingAcl

source

impl Decodable for DeleteAclsResponse

source

impl Decodable for DeleteGroupsRequest

source

impl Decodable for DeleteGroupsResponse

source

impl Decodable for DeleteRecordsPartition

source

impl Decodable for DeleteRecordsRequest

source

impl Decodable for DeleteRecordsTopic

source

impl Decodable for DeleteRecordsResponse

source

impl Decodable for DeleteTopicState

source

impl Decodable for DeleteTopicsRequest

source

impl Decodable for DeleteTopicsResponse

source

impl Decodable for DescribeAclsRequest

source

impl Decodable for AclDescription

source

impl Decodable for DescribeAclsResource

source

impl Decodable for DescribeAclsResponse

source

impl Decodable for ComponentData

source

impl Decodable for DescribeClientQuotasRequest

source

impl Decodable for DescribeClientQuotasResponse

source

impl Decodable for kafka_protocol::messages::describe_client_quotas_response::EntityData

source

impl Decodable for kafka_protocol::messages::describe_client_quotas_response::EntryData

source

impl Decodable for ValueData

source

impl Decodable for DescribeClusterRequest

source

impl Decodable for DescribeClusterResponse

source

impl Decodable for DescribeConfigsRequest

source

impl Decodable for DescribeConfigsResource

source

impl Decodable for DescribeConfigsResourceResult

source

impl Decodable for DescribeConfigsResponse

source

impl Decodable for DescribeConfigsResult

source

impl Decodable for DescribeConfigsSynonym

source

impl Decodable for DescribeDelegationTokenOwner

source

impl Decodable for DescribeDelegationTokenRequest

source

impl Decodable for DescribeDelegationTokenResponse

source

impl Decodable for DescribedDelegationToken

source

impl Decodable for DescribedDelegationTokenRenewer

source

impl Decodable for DescribeGroupsRequest

source

impl Decodable for DescribeGroupsResponse

source

impl Decodable for DescribedGroup

source

impl Decodable for DescribedGroupMember

source

impl Decodable for DescribeLogDirsRequest

source

impl Decodable for DescribeLogDirsPartition

source

impl Decodable for DescribeLogDirsResponse

source

impl Decodable for DescribeLogDirsResult

source

impl Decodable for DescribeLogDirsTopic

source

impl Decodable for DescribeProducersRequest

source

impl Decodable for TopicRequest

source

impl Decodable for DescribeProducersResponse

source

impl Decodable for PartitionResponse

source

impl Decodable for ProducerState

source

impl Decodable for TopicResponse

source

impl Decodable for DescribeQuorumRequest

source

impl Decodable for kafka_protocol::messages::describe_quorum_request::PartitionData

source

impl Decodable for kafka_protocol::messages::describe_quorum_request::TopicData

source

impl Decodable for DescribeQuorumResponse

source

impl Decodable for kafka_protocol::messages::describe_quorum_response::PartitionData

source

impl Decodable for ReplicaState

source

impl Decodable for kafka_protocol::messages::describe_quorum_response::TopicData

source

impl Decodable for DescribeTransactionsRequest

source

impl Decodable for DescribeTransactionsResponse

source

impl Decodable for kafka_protocol::messages::describe_transactions_response::TransactionState

source

impl Decodable for DescribeUserScramCredentialsRequest

source

impl Decodable for UserName

source

impl Decodable for CredentialInfo

source

impl Decodable for DescribeUserScramCredentialsResponse

source

impl Decodable for DescribeUserScramCredentialsResult

source

impl Decodable for ElectLeadersRequest

source

impl Decodable for ElectLeadersResponse

source

impl Decodable for PartitionResult

source

impl Decodable for ReplicaElectionResult

source

impl Decodable for EndQuorumEpochRequest

source

impl Decodable for kafka_protocol::messages::end_quorum_epoch_request::PartitionData

source

impl Decodable for kafka_protocol::messages::end_quorum_epoch_request::TopicData

source

impl Decodable for EndQuorumEpochResponse

source

impl Decodable for kafka_protocol::messages::end_quorum_epoch_response::PartitionData

source

impl Decodable for kafka_protocol::messages::end_quorum_epoch_response::TopicData

source

impl Decodable for EndTxnRequest

source

impl Decodable for EndTxnResponse

source

impl Decodable for EnvelopeRequest

source

impl Decodable for EnvelopeResponse

source

impl Decodable for ExpireDelegationTokenRequest

source

impl Decodable for ExpireDelegationTokenResponse

source

impl Decodable for FetchPartition

source

impl Decodable for FetchRequest

source

impl Decodable for FetchTopic

source

impl Decodable for ForgottenTopic

source

impl Decodable for AbortedTransaction

source

impl Decodable for kafka_protocol::messages::fetch_response::EpochEndOffset

source

impl Decodable for FetchResponse

source

impl Decodable for FetchableTopicResponse

source

impl Decodable for kafka_protocol::messages::fetch_response::LeaderIdAndEpoch

source

impl Decodable for kafka_protocol::messages::fetch_response::PartitionData

source

impl Decodable for kafka_protocol::messages::fetch_response::SnapshotId

source

impl Decodable for FetchSnapshotRequest

source

impl Decodable for kafka_protocol::messages::fetch_snapshot_request::PartitionSnapshot

source

impl Decodable for kafka_protocol::messages::fetch_snapshot_request::SnapshotId

source

impl Decodable for kafka_protocol::messages::fetch_snapshot_request::TopicSnapshot

source

impl Decodable for FetchSnapshotResponse

source

impl Decodable for kafka_protocol::messages::fetch_snapshot_response::LeaderIdAndEpoch

source

impl Decodable for kafka_protocol::messages::fetch_snapshot_response::PartitionSnapshot

source

impl Decodable for kafka_protocol::messages::fetch_snapshot_response::SnapshotId

source

impl Decodable for kafka_protocol::messages::fetch_snapshot_response::TopicSnapshot

source

impl Decodable for FindCoordinatorRequest

source

impl Decodable for Coordinator

source

impl Decodable for FindCoordinatorResponse

source

impl Decodable for HeartbeatRequest

source

impl Decodable for HeartbeatResponse

source

impl Decodable for kafka_protocol::messages::incremental_alter_configs_request::AlterConfigsResource

source

impl Decodable for AlterableConfig

source

impl Decodable for IncrementalAlterConfigsRequest

source

impl Decodable for kafka_protocol::messages::incremental_alter_configs_response::AlterConfigsResourceResponse

source

impl Decodable for IncrementalAlterConfigsResponse

source

impl Decodable for InitProducerIdRequest

source

impl Decodable for InitProducerIdResponse

source

impl Decodable for JoinGroupRequest

source

impl Decodable for JoinGroupResponse

source

impl Decodable for JoinGroupResponseMember

source

impl Decodable for LeaderAndIsrLiveLeader

source

impl Decodable for LeaderAndIsrPartitionState

source

impl Decodable for LeaderAndIsrRequest

source

impl Decodable for LeaderAndIsrTopicState

source

impl Decodable for LeaderAndIsrPartitionError

source

impl Decodable for LeaderAndIsrResponse

source

impl Decodable for LeaderChangeMessage

source

impl Decodable for Voter

source

impl Decodable for LeaveGroupRequest

source

impl Decodable for MemberIdentity

source

impl Decodable for LeaveGroupResponse

source

impl Decodable for MemberResponse

source

impl Decodable for ListGroupsRequest

source

impl Decodable for ListGroupsResponse

source

impl Decodable for ListedGroup

source

impl Decodable for ListOffsetsPartition

source

impl Decodable for ListOffsetsRequest

source

impl Decodable for ListOffsetsTopic

source

impl Decodable for ListOffsetsPartitionResponse

source

impl Decodable for ListOffsetsResponse

source

impl Decodable for ListOffsetsTopicResponse

source

impl Decodable for ListPartitionReassignmentsRequest

source

impl Decodable for ListPartitionReassignmentsTopics

source

impl Decodable for ListPartitionReassignmentsResponse

source

impl Decodable for OngoingPartitionReassignment

source

impl Decodable for OngoingTopicReassignment

source

impl Decodable for ListTransactionsRequest

source

impl Decodable for ListTransactionsResponse

source

impl Decodable for kafka_protocol::messages::list_transactions_response::TransactionState

source

impl Decodable for MetadataRequest

source

impl Decodable for MetadataRequestTopic

source

impl Decodable for MetadataResponse

source

impl Decodable for MetadataResponsePartition

source

impl Decodable for OffsetCommitRequest

source

impl Decodable for OffsetCommitRequestPartition

source

impl Decodable for OffsetCommitRequestTopic

source

impl Decodable for OffsetCommitResponse

source

impl Decodable for OffsetCommitResponsePartition

source

impl Decodable for OffsetCommitResponseTopic

source

impl Decodable for OffsetDeleteRequest

source

impl Decodable for OffsetDeleteRequestPartition

source

impl Decodable for OffsetDeleteResponse

source

impl Decodable for OffsetFetchRequest

source

impl Decodable for OffsetFetchRequestGroup

source

impl Decodable for OffsetFetchRequestTopic

source

impl Decodable for OffsetFetchRequestTopics

source

impl Decodable for OffsetFetchResponse

source

impl Decodable for OffsetFetchResponseGroup

source

impl Decodable for OffsetFetchResponsePartition

source

impl Decodable for OffsetFetchResponsePartitions

source

impl Decodable for OffsetFetchResponseTopic

source

impl Decodable for OffsetFetchResponseTopics

source

impl Decodable for OffsetForLeaderEpochRequest

source

impl Decodable for OffsetForLeaderPartition

source

impl Decodable for kafka_protocol::messages::offset_for_leader_epoch_response::EpochEndOffset

source

impl Decodable for OffsetForLeaderEpochResponse

source

impl Decodable for PartitionProduceData

source

impl Decodable for ProduceRequest

source

impl Decodable for BatchIndexAndErrorMessage

source

impl Decodable for PartitionProduceResponse

source

impl Decodable for ProduceResponse

source

impl Decodable for RenewDelegationTokenRequest

source

impl Decodable for RenewDelegationTokenResponse

source

impl Decodable for RequestHeader

source

impl Decodable for ResponseHeader

source

impl Decodable for SaslAuthenticateRequest

source

impl Decodable for SaslAuthenticateResponse

source

impl Decodable for SaslHandshakeRequest

source

impl Decodable for SaslHandshakeResponse

source

impl Decodable for SnapshotFooterRecord

source

impl Decodable for SnapshotHeaderRecord

source

impl Decodable for StopReplicaPartitionState

source

impl Decodable for StopReplicaPartitionV0

source

impl Decodable for StopReplicaRequest

source

impl Decodable for StopReplicaTopicState

source

impl Decodable for StopReplicaTopicV1

source

impl Decodable for StopReplicaPartitionError

source

impl Decodable for StopReplicaResponse

source

impl Decodable for SyncGroupRequest

source

impl Decodable for SyncGroupRequestAssignment

source

impl Decodable for SyncGroupResponse

source

impl Decodable for TxnOffsetCommitRequest

source

impl Decodable for TxnOffsetCommitRequestPartition

source

impl Decodable for TxnOffsetCommitRequestTopic

source

impl Decodable for TxnOffsetCommitResponse

source

impl Decodable for TxnOffsetCommitResponsePartition

source

impl Decodable for TxnOffsetCommitResponseTopic

source

impl Decodable for UnregisterBrokerRequest

source

impl Decodable for UnregisterBrokerResponse

source

impl Decodable for UpdateFeaturesRequest

source

impl Decodable for UpdateFeaturesResponse

source

impl Decodable for UpdateMetadataBroker

source

impl Decodable for UpdateMetadataEndpoint

source

impl Decodable for UpdateMetadataPartitionState

source

impl Decodable for UpdateMetadataRequest

source

impl Decodable for UpdateMetadataTopicState

source

impl Decodable for UpdateMetadataResponse

source

impl Decodable for kafka_protocol::messages::vote_request::PartitionData

source

impl Decodable for kafka_protocol::messages::vote_request::TopicData

source

impl Decodable for VoteRequest

source

impl Decodable for kafka_protocol::messages::vote_response::PartitionData

source

impl Decodable for kafka_protocol::messages::vote_response::TopicData

source

impl Decodable for VoteResponse

source

impl Decodable for WritableTxnMarker

source

impl Decodable for WritableTxnMarkerTopic

source

impl Decodable for WriteTxnMarkersRequest

source

impl Decodable for WritableTxnMarkerPartitionResult

source

impl Decodable for WritableTxnMarkerResult

source

impl Decodable for WritableTxnMarkerTopicResult

source

Trait kafka_protocol::protocol::Decodable

Required methods

fn decode<B: ByteBuf>(buf: &mut B, version: i16) -> Result<Self, DecodeError>

Implementors

impl Decodable for AddOffsetsToTxnRequest

impl Decodable for AddOffsetsToTxnResponse

impl Decodable for AddPartitionsToTxnRequest

impl Decodable for AddPartitionsToTxnResponse

impl Decodable for AllocateProducerIdsRequest

impl Decodable for AllocateProducerIdsResponse

impl Decodable for AlterClientQuotasRequest

impl Decodable for kafka_protocol::messages::alter_client_quotas_request::EntityData

impl Decodable for kafka_protocol::messages::alter_client_quotas_request::EntryData

impl Decodable for OpData

impl Decodable for AlterClientQuotasResponse

impl Decodable for kafka_protocol::messages::alter_client_quotas_response::EntityData

impl Decodable for kafka_protocol::messages::alter_client_quotas_response::EntryData

impl Decodable for AlterConfigsRequest

impl Decodable for kafka_protocol::messages::alter_configs_request::AlterConfigsResource

impl Decodable for kafka_protocol::messages::alter_configs_response::AlterConfigsResourceResponse

impl Decodable for AlterConfigsResponse

impl Decodable for AlterIsrRequest

impl Decodable for kafka_protocol::messages::alter_isr_request::PartitionData

impl Decodable for kafka_protocol::messages::alter_isr_request::TopicData

impl Decodable for AlterIsrResponse

impl Decodable for kafka_protocol::messages::alter_isr_response::PartitionData

impl Decodable for kafka_protocol::messages::alter_isr_response::TopicData

impl Decodable for AlterPartitionReassignmentsRequest

impl Decodable for ReassignablePartition

impl Decodable for ReassignableTopic

impl Decodable for AlterPartitionReassignmentsResponse

impl Decodable for ReassignablePartitionResponse

impl Decodable for ReassignableTopicResponse

impl Decodable for AlterReplicaLogDirsRequest

impl Decodable for AlterReplicaLogDirPartitionResult

impl Decodable for AlterReplicaLogDirTopicResult

impl Decodable for AlterReplicaLogDirsResponse

impl Decodable for AlterUserScramCredentialsRequest

impl Decodable for ScramCredentialDeletion

impl Decodable for ScramCredentialUpsertion

impl Decodable for AlterUserScramCredentialsResponse

impl Decodable for AlterUserScramCredentialsResult

impl Decodable for ApiVersionsRequest

impl Decodable for ApiVersionsResponse

impl Decodable for BeginQuorumEpochRequest

impl Decodable for kafka_protocol::messages::begin_quorum_epoch_request::PartitionData

impl Decodable for kafka_protocol::messages::begin_quorum_epoch_request::TopicData

impl Decodable for BeginQuorumEpochResponse

impl Decodable for kafka_protocol::messages::begin_quorum_epoch_response::PartitionData

impl Decodable for kafka_protocol::messages::begin_quorum_epoch_response::TopicData

impl Decodable for BrokerHeartbeatRequest

impl Decodable for BrokerHeartbeatResponse

impl Decodable for BrokerRegistrationRequest

impl Decodable for BrokerRegistrationResponse

impl Decodable for ConsumerProtocolAssignment

impl Decodable for ConsumerProtocolSubscription

impl Decodable for ControlledShutdownRequest

impl Decodable for ControlledShutdownResponse

impl Decodable for RemainingPartition

impl Decodable for AclCreation

impl Decodable for CreateAclsRequest

impl Decodable for AclCreationResult

impl Decodable for CreateAclsResponse

impl Decodable for CreatableRenewers

impl Decodable for CreateDelegationTokenRequest

impl Decodable for CreateDelegationTokenResponse

impl Decodable for CreatePartitionsAssignment

impl Decodable for CreatePartitionsRequest

impl Decodable for CreatePartitionsResponse

impl Decodable for CreatePartitionsTopicResult

impl Decodable for CreateTopicsRequest

impl Decodable for CreatableTopicConfigs

impl Decodable for CreateTopicsResponse

impl Decodable for DefaultPrincipalData

impl Decodable for DeleteAclsFilter

impl Decodable for DeleteAclsRequest

impl Decodable for DeleteAclsFilterResult

impl Decodable for DeleteAclsMatchingAcl

impl Decodable for DeleteAclsResponse

impl Decodable for DeleteGroupsRequest