Trait kafka_protocol::protocol::Decodable

source · 
pub trait Decodable: Sized {
    // Required method
    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.

Object Safety§

This trait is not object safe.

Implementors§

source§

impl Decodable for AddOffsetsToTxnRequest

source§

impl Decodable for AddOffsetsToTxnResponse

source§

impl Decodable for AddPartitionsToTxnRequest

source§

impl Decodable for AddPartitionsToTxnResponse

source§

impl Decodable for AllocateProducerIdsRequest

source§

impl Decodable for AllocateProducerIdsResponse

source§

impl Decodable for AlterClientQuotasRequest

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 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 AlterPartitionRequest

source§

impl Decodable for BrokerState

source§

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

source§

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

source§

impl Decodable for AlterPartitionResponse

source§

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

source§

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

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 AssignReplicasToDirsRequest

source§

impl Decodable for kafka_protocol::messages::assign_replicas_to_dirs_request::DirectoryData

source§

impl Decodable for kafka_protocol::messages::assign_replicas_to_dirs_request::PartitionData

source§

impl Decodable for kafka_protocol::messages::assign_replicas_to_dirs_request::TopicData

source§

impl Decodable for AssignReplicasToDirsResponse

source§

impl Decodable for kafka_protocol::messages::assign_replicas_to_dirs_response::DirectoryData

source§

impl Decodable for kafka_protocol::messages::assign_replicas_to_dirs_response::PartitionData

source§

impl Decodable for kafka_protocol::messages::assign_replicas_to_dirs_response::TopicData

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 ConsumerGroupHeartbeatRequest

source§

impl Decodable for kafka_protocol::messages::consumer_group_heartbeat_request::TopicPartitions

source§

impl Decodable for Assignment

source§

impl Decodable for ConsumerGroupHeartbeatResponse

source§

impl Decodable for kafka_protocol::messages::consumer_group_heartbeat_response::TopicPartitions

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 ControllerRegistrationRequest

source§

impl Decodable for ControllerRegistrationResponse

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 kafka_protocol::messages::describe_quorum_response::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 kafka_protocol::messages::fetch_request::ReplicaState

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 GetTelemetrySubscriptionsRequest

source§

impl Decodable for GetTelemetrySubscriptionsResponse

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 ListClientMetricsResourcesRequest

source§

impl Decodable for ClientMetricsResource

source§

impl Decodable for ListClientMetricsResourcesResponse

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 kafka_protocol::messages::produce_response::LeaderIdAndEpoch

source§

impl Decodable for PartitionProduceResponse

source§

impl Decodable for ProduceResponse

source§

impl Decodable for PushTelemetryRequest

source§

impl Decodable for PushTelemetryResponse

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§

impl Decodable for WriteTxnMarkersResponse