Trait kafka_protocol::protocol::Decodable

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

A decodable message.

Required Methods

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

Decode the message from the provided buffer and version.

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 AlterPartitionReassignmentsRequest

impl Decodable for ReassignablePartition

impl Decodable for ReassignableTopic

impl Decodable for AlterPartitionReassignmentsResponse

impl Decodable for ReassignablePartitionResponse

impl Decodable for ReassignableTopicResponse

impl Decodable for AlterPartitionRequest

impl Decodable for kafka_protocol::messages::alter_partition_request::PartitionData

impl Decodable for kafka_protocol::messages::alter_partition_request::TopicData

impl Decodable for AlterPartitionResponse

impl Decodable for kafka_protocol::messages::alter_partition_response::PartitionData

impl Decodable for kafka_protocol::messages::alter_partition_response::TopicData

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

impl Decodable for DeleteGroupsResponse

impl Decodable for DeleteRecordsPartition

impl Decodable for DeleteRecordsRequest

impl Decodable for DeleteRecordsTopic

impl Decodable for DeleteRecordsResponse

impl Decodable for DeleteTopicState

impl Decodable for DeleteTopicsRequest

impl Decodable for DeleteTopicsResponse

impl Decodable for DescribeAclsRequest

impl Decodable for AclDescription

impl Decodable for DescribeAclsResource

impl Decodable for DescribeAclsResponse

impl Decodable for ComponentData

impl Decodable for DescribeClientQuotasRequest

impl Decodable for DescribeClientQuotasResponse

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

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

impl Decodable for ValueData

impl Decodable for DescribeClusterRequest

impl Decodable for DescribeClusterResponse

impl Decodable for DescribeConfigsRequest

impl Decodable for DescribeConfigsResource

impl Decodable for DescribeConfigsResourceResult

impl Decodable for DescribeConfigsResponse

impl Decodable for DescribeConfigsResult

impl Decodable for DescribeConfigsSynonym

impl Decodable for DescribeDelegationTokenOwner

impl Decodable for DescribeDelegationTokenRequest

impl Decodable for DescribeDelegationTokenResponse

impl Decodable for DescribedDelegationToken

impl Decodable for DescribedDelegationTokenRenewer

impl Decodable for DescribeGroupsRequest

impl Decodable for DescribeGroupsResponse

impl Decodable for DescribedGroup

impl Decodable for DescribedGroupMember

impl Decodable for DescribeLogDirsRequest

impl Decodable for DescribeLogDirsPartition

impl Decodable for DescribeLogDirsResponse

impl Decodable for DescribeLogDirsResult

impl Decodable for DescribeLogDirsTopic

impl Decodable for DescribeProducersRequest

impl Decodable for TopicRequest

impl Decodable for DescribeProducersResponse

impl Decodable for PartitionResponse

impl Decodable for ProducerState

impl Decodable for TopicResponse

impl Decodable for DescribeQuorumRequest

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

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

impl Decodable for DescribeQuorumResponse

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

impl Decodable for ReplicaState

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

impl Decodable for DescribeTransactionsRequest

impl Decodable for DescribeTransactionsResponse

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

impl Decodable for DescribeUserScramCredentialsRequest

impl Decodable for UserName

impl Decodable for CredentialInfo

impl Decodable for DescribeUserScramCredentialsResponse

impl Decodable for DescribeUserScramCredentialsResult

impl Decodable for ElectLeadersRequest

impl Decodable for ElectLeadersResponse

impl Decodable for PartitionResult

impl Decodable for ReplicaElectionResult

impl Decodable for EndQuorumEpochRequest

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

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

impl Decodable for EndQuorumEpochResponse

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

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

impl Decodable for EndTxnRequest

impl Decodable for EndTxnResponse

impl Decodable for EnvelopeRequest

impl Decodable for EnvelopeResponse

impl Decodable for ExpireDelegationTokenRequest

impl Decodable for ExpireDelegationTokenResponse

impl Decodable for FetchPartition

impl Decodable for FetchRequest

impl Decodable for FetchTopic

impl Decodable for ForgottenTopic

impl Decodable for AbortedTransaction

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

impl Decodable for FetchResponse

impl Decodable for FetchableTopicResponse

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

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

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

impl Decodable for FetchSnapshotRequest

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

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

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

impl Decodable for FetchSnapshotResponse

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

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

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

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

impl Decodable for FindCoordinatorRequest

impl Decodable for Coordinator

impl Decodable for FindCoordinatorResponse

impl Decodable for HeartbeatRequest

impl Decodable for HeartbeatResponse

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

impl Decodable for AlterableConfig

impl Decodable for IncrementalAlterConfigsRequest

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

impl Decodable for IncrementalAlterConfigsResponse

impl Decodable for InitProducerIdRequest

impl Decodable for InitProducerIdResponse

impl Decodable for JoinGroupRequest

impl Decodable for JoinGroupResponse

impl Decodable for JoinGroupResponseMember

impl Decodable for LeaderAndIsrLiveLeader

impl Decodable for LeaderAndIsrPartitionState

impl Decodable for LeaderAndIsrRequest

impl Decodable for LeaderAndIsrTopicState

impl Decodable for LeaderAndIsrPartitionError

impl Decodable for LeaderAndIsrResponse

impl Decodable for LeaderChangeMessage

impl Decodable for Voter

impl Decodable for LeaveGroupRequest

impl Decodable for MemberIdentity

impl Decodable for LeaveGroupResponse

impl Decodable for MemberResponse

impl Decodable for ListGroupsRequest

impl Decodable for ListGroupsResponse

impl Decodable for ListedGroup

impl Decodable for ListOffsetsPartition

impl Decodable for ListOffsetsRequest

impl Decodable for ListOffsetsTopic

impl Decodable for ListOffsetsPartitionResponse

impl Decodable for ListOffsetsResponse

impl Decodable for ListOffsetsTopicResponse

impl Decodable for ListPartitionReassignmentsRequest

impl Decodable for ListPartitionReassignmentsTopics

impl Decodable for ListPartitionReassignmentsResponse

impl Decodable for OngoingPartitionReassignment

impl Decodable for OngoingTopicReassignment

impl Decodable for ListTransactionsRequest

impl Decodable for ListTransactionsResponse

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

impl Decodable for MetadataRequest

impl Decodable for MetadataRequestTopic

impl Decodable for MetadataResponse

impl Decodable for MetadataResponsePartition

impl Decodable for OffsetCommitRequest

impl Decodable for OffsetCommitRequestPartition

impl Decodable for OffsetCommitRequestTopic

impl Decodable for OffsetCommitResponse

impl Decodable for OffsetCommitResponsePartition

impl Decodable for OffsetCommitResponseTopic

impl Decodable for OffsetDeleteRequest

impl Decodable for OffsetDeleteRequestPartition

impl Decodable for OffsetDeleteResponse

impl Decodable for OffsetFetchRequest

impl Decodable for OffsetFetchRequestGroup

impl Decodable for OffsetFetchRequestTopic

impl Decodable for OffsetFetchRequestTopics

impl Decodable for OffsetFetchResponse

impl Decodable for OffsetFetchResponseGroup

impl Decodable for OffsetFetchResponsePartition

impl Decodable for OffsetFetchResponsePartitions

impl Decodable for OffsetFetchResponseTopic

impl Decodable for OffsetFetchResponseTopics

impl Decodable for OffsetForLeaderEpochRequest

impl Decodable for OffsetForLeaderPartition

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

impl Decodable for OffsetForLeaderEpochResponse

impl Decodable for PartitionProduceData

impl Decodable for ProduceRequest

impl Decodable for BatchIndexAndErrorMessage

impl Decodable for PartitionProduceResponse

impl Decodable for ProduceResponse

impl Decodable for RenewDelegationTokenRequest

impl Decodable for RenewDelegationTokenResponse

impl Decodable for RequestHeader

impl Decodable for ResponseHeader

impl Decodable for SaslAuthenticateRequest

impl Decodable for SaslAuthenticateResponse

impl Decodable for SaslHandshakeRequest

impl Decodable for SaslHandshakeResponse

impl Decodable for SnapshotFooterRecord

impl Decodable for SnapshotHeaderRecord

impl Decodable for StopReplicaPartitionState

impl Decodable for StopReplicaPartitionV0

impl Decodable for StopReplicaRequest

impl Decodable for StopReplicaTopicState

impl Decodable for StopReplicaTopicV1

impl Decodable for StopReplicaPartitionError

impl Decodable for StopReplicaResponse

impl Decodable for SyncGroupRequest

impl Decodable for SyncGroupRequestAssignment

impl Decodable for SyncGroupResponse

impl Decodable for TxnOffsetCommitRequest

impl Decodable for TxnOffsetCommitRequestPartition

impl Decodable for TxnOffsetCommitRequestTopic

impl Decodable for TxnOffsetCommitResponse

impl Decodable for TxnOffsetCommitResponsePartition

impl Decodable for TxnOffsetCommitResponseTopic

impl Decodable for UnregisterBrokerRequest

impl Decodable for UnregisterBrokerResponse

impl Decodable for UpdateFeaturesRequest

impl Decodable for UpdateFeaturesResponse

impl Decodable for UpdateMetadataBroker

impl Decodable for UpdateMetadataEndpoint

impl Decodable for UpdateMetadataPartitionState

impl Decodable for UpdateMetadataRequest

impl Decodable for UpdateMetadataTopicState

impl Decodable for UpdateMetadataResponse

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

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

impl Decodable for VoteRequest

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

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

impl Decodable for VoteResponse

impl Decodable for WritableTxnMarker

impl Decodable for WritableTxnMarkerTopic

impl Decodable for WriteTxnMarkersRequest

impl Decodable for WritableTxnMarkerPartitionResult

impl Decodable for WritableTxnMarkerResult

impl Decodable for WritableTxnMarkerTopicResult

impl Decodable for WriteTxnMarkersResponse