Trait Decode 

pub trait Decode<'de>: Sized {
    // Required method
    fn decode<B: Buf>(buf: &mut B, version: i16) -> Result<Self, ProtocolError>;
}

Decode a Kafka wire-protocol value from a buffer at the given protocol version.

The 'de lifetime is the lifetime the decoded value may borrow from the input. Owned-flavor types implement Decode<'de> for any 'de (their output is 'static). Borrowed-flavor types implement Decode<'de> where Self: 'de.

Required Methods

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

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_response::AbortedTransaction

impl Decode<'_> for crabka_protocol::owned::fetch_response::AbortedTransaction

impl Decode<'_> for AccessControlEntryRecord

impl Decode<'_> for AcknowledgePartition

impl Decode<'_> for AcknowledgeTopic

impl Decode<'_> for crabka_protocol::owned::share_acknowledge_request::AcknowledgementBatch

impl Decode<'_> for crabka_protocol::owned::share_fetch_request::AcknowledgementBatch

impl Decode<'_> for AclCreation

impl Decode<'_> for AclCreationResult

impl Decode<'_> for AclDescription

impl Decode<'_> for AcquiredRecords

impl Decode<'_> for AddOffsetsToTxnRequest

impl Decode<'_> for AddOffsetsToTxnResponse

impl Decode<'_> for AddPartitionsToTxnPartitionResult

impl Decode<'_> for AddPartitionsToTxnRequest

impl Decode<'_> for AddPartitionsToTxnResponse

impl Decode<'_> for AddPartitionsToTxnResult

impl Decode<'_> for AddPartitionsToTxnTopic

impl Decode<'_> for AddPartitionsToTxnTopicResult

impl Decode<'_> for AddPartitionsToTxnTransaction

impl Decode<'_> for AddRaftVoterRequest

impl Decode<'_> for AddRaftVoterResponse

impl Decode<'_> for AllocateProducerIdsRequest

impl Decode<'_> for AllocateProducerIdsResponse

impl Decode<'_> for AlterClientQuotasRequest

impl Decode<'_> for AlterClientQuotasResponse

impl Decode<'_> for AlterConfigsRequest

impl Decode<'_> for crabka_protocol::owned::alter_configs_request::AlterConfigsResource

impl Decode<'_> for crabka_protocol::owned::incremental_alter_configs_request::AlterConfigsResource

impl Decode<'_> for crabka_protocol::owned::alter_configs_response::AlterConfigsResourceResponse

impl Decode<'_> for crabka_protocol::owned::incremental_alter_configs_response::AlterConfigsResourceResponse

impl Decode<'_> for AlterConfigsResponse

impl Decode<'_> for AlterPartitionReassignmentsRequest

impl Decode<'_> for AlterPartitionReassignmentsResponse

impl Decode<'_> for AlterPartitionRequest

impl Decode<'_> for AlterPartitionResponse

impl Decode<'_> for AlterReplicaLogDir

impl Decode<'_> for AlterReplicaLogDirPartitionResult

impl Decode<'_> for AlterReplicaLogDirTopic

impl Decode<'_> for AlterReplicaLogDirTopicResult

impl Decode<'_> for AlterReplicaLogDirsRequest

impl Decode<'_> for AlterReplicaLogDirsResponse

impl Decode<'_> for AlterShareGroupOffsetsRequest

impl Decode<'_> for AlterShareGroupOffsetsRequestPartition

impl Decode<'_> for AlterShareGroupOffsetsRequestTopic

impl Decode<'_> for AlterShareGroupOffsetsResponse

impl Decode<'_> for AlterShareGroupOffsetsResponsePartition

impl Decode<'_> for AlterShareGroupOffsetsResponseTopic

impl Decode<'_> for AlterUserScramCredentialsRequest

impl Decode<'_> for AlterUserScramCredentialsResponse

impl Decode<'_> for AlterUserScramCredentialsResult

impl Decode<'_> for crabka_protocol::owned::alter_configs_request::AlterableConfig

impl Decode<'_> for crabka_protocol::owned::incremental_alter_configs_request::AlterableConfig

impl Decode<'_> for ApiVersion

impl Decode<'_> for ApiVersionsRequest

impl Decode<'_> for ApiVersionsResponse

impl Decode<'_> for AssignReplicasToDirsRequest

impl Decode<'_> for AssignReplicasToDirsResponse

impl Decode<'_> for crabka_protocol::owned::common::consumer_group_describe_response::assignment::Assignment

impl Decode<'_> for crabka_protocol::owned::common::share_group_describe_response::assignment::Assignment

impl Decode<'_> for crabka_protocol::owned::common::streams_group_describe_response::assignment::Assignment

impl Decode<'_> for crabka_protocol::owned::consumer_group_heartbeat_response::Assignment

impl Decode<'_> for crabka_protocol::owned::share_group_heartbeat_response::Assignment

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::produce_response::BatchIndexAndErrorMessage

impl Decode<'_> for crabka_protocol::owned::produce_response::BatchIndexAndErrorMessage

impl Decode<'_> for BeginQuorumEpochRequest

impl Decode<'_> for BeginQuorumEpochResponse

impl Decode<'_> for BeginTransactionRecord

impl Decode<'_> for BrokerEndpoint

impl Decode<'_> for BrokerFeature

impl Decode<'_> for BrokerHeartbeatRequest

impl Decode<'_> for BrokerHeartbeatResponse

impl Decode<'_> for BrokerRegistrationChangeRecord

impl Decode<'_> for BrokerRegistrationRequest

impl Decode<'_> for BrokerRegistrationResponse

impl Decode<'_> for BrokerState

impl Decode<'_> for ClientQuotaRecord

impl Decode<'_> for ComponentData

impl Decode<'_> for ConfigRecord

impl Decode<'_> for ConfigResource

impl Decode<'_> for ConsumerGroupDescribeRequest

impl Decode<'_> for ConsumerGroupDescribeResponse

impl Decode<'_> for ConsumerGroupHeartbeatRequest

impl Decode<'_> for ConsumerGroupHeartbeatResponse

impl Decode<'_> for ConsumerProtocolAssignment

impl Decode<'_> for ConsumerProtocolSubscription

impl Decode<'_> for ControlRecordTypeSchema

impl Decode<'_> for ControllerEndpoint

impl Decode<'_> for ControllerFeature

impl Decode<'_> for ControllerRegistrationRequest

impl Decode<'_> for ControllerRegistrationResponse

impl Decode<'_> for Coordinator

impl Decode<'_> for CopartitionGroup

impl Decode<'_> for CreatableRenewers

impl Decode<'_> for CreatableReplicaAssignment

impl Decode<'_> for CreatableTopic

impl Decode<'_> for CreatableTopicConfig

impl Decode<'_> for CreatableTopicConfigs

impl Decode<'_> for CreatableTopicResult

impl Decode<'_> for CreateAclsRequest

impl Decode<'_> for CreateAclsResponse

impl Decode<'_> for CreateDelegationTokenRequest

impl Decode<'_> for CreateDelegationTokenResponse

impl Decode<'_> for CreatePartitionsAssignment

impl Decode<'_> for CreatePartitionsRequest

impl Decode<'_> for CreatePartitionsResponse

impl Decode<'_> for CreatePartitionsTopic

impl Decode<'_> for CreatePartitionsTopicResult

impl Decode<'_> for CreateTopicsRequest

impl Decode<'_> for CreateTopicsResponse

impl Decode<'_> for CredentialInfo

impl Decode<'_> for CurrentLeader

impl Decode<'_> for crabka_protocol::owned::describe_topic_partitions_request::Cursor

impl Decode<'_> for crabka_protocol::owned::describe_topic_partitions_response::Cursor

impl Decode<'_> for DefaultPrincipalData

impl Decode<'_> for DelegationTokenRecord

impl Decode<'_> for DeletableGroupResult

impl Decode<'_> for DeletableTopicResult

impl Decode<'_> for DeleteAclsFilter

impl Decode<'_> for DeleteAclsFilterResult

impl Decode<'_> for DeleteAclsMatchingAcl

impl Decode<'_> for DeleteAclsRequest

impl Decode<'_> for DeleteAclsResponse

impl Decode<'_> for DeleteGroupsRequest

impl Decode<'_> for DeleteGroupsResponse

impl Decode<'_> for DeleteRecordsPartition

impl Decode<'_> for DeleteRecordsPartitionResult

impl Decode<'_> for DeleteRecordsRequest

impl Decode<'_> for DeleteRecordsResponse

impl Decode<'_> for DeleteRecordsTopic

impl Decode<'_> for DeleteRecordsTopicResult

impl Decode<'_> for DeleteShareGroupOffsetsRequest

impl Decode<'_> for DeleteShareGroupOffsetsRequestTopic

impl Decode<'_> for DeleteShareGroupOffsetsResponse

impl Decode<'_> for DeleteShareGroupOffsetsResponseTopic

impl Decode<'_> for DeleteShareGroupStateRequest

impl Decode<'_> for DeleteShareGroupStateResponse

impl Decode<'_> for DeleteStateData

impl Decode<'_> for DeleteStateResult

impl Decode<'_> for DeleteTopicState

impl Decode<'_> for DeleteTopicsRequest

impl Decode<'_> for DeleteTopicsResponse

impl Decode<'_> for DescribableLogDirTopic

impl Decode<'_> for DescribeAclsRequest

impl Decode<'_> for DescribeAclsResource

impl Decode<'_> for DescribeAclsResponse

impl Decode<'_> for DescribeClientQuotasRequest

impl Decode<'_> for DescribeClientQuotasResponse

impl Decode<'_> for DescribeClusterBroker

impl Decode<'_> for DescribeClusterRequest

impl Decode<'_> for DescribeClusterResponse

impl Decode<'_> for DescribeConfigsRequest

impl Decode<'_> for DescribeConfigsResource

impl Decode<'_> for DescribeConfigsResourceResult

impl Decode<'_> for DescribeConfigsResponse

impl Decode<'_> for DescribeConfigsResult

impl Decode<'_> for DescribeConfigsSynonym

impl Decode<'_> for DescribeDelegationTokenOwner

impl Decode<'_> for DescribeDelegationTokenRequest

impl Decode<'_> for DescribeDelegationTokenResponse

impl Decode<'_> for DescribeGroupsRequest

impl Decode<'_> for DescribeGroupsResponse

impl Decode<'_> for DescribeLogDirsPartition

impl Decode<'_> for DescribeLogDirsRequest

impl Decode<'_> for DescribeLogDirsResponse

impl Decode<'_> for DescribeLogDirsResult

impl Decode<'_> for DescribeLogDirsTopic

impl Decode<'_> for DescribeProducersRequest

impl Decode<'_> for DescribeProducersResponse

impl Decode<'_> for DescribeQuorumRequest

impl Decode<'_> for DescribeQuorumResponse

impl Decode<'_> for DescribeShareGroupOffsetsRequest

impl Decode<'_> for DescribeShareGroupOffsetsRequestGroup

impl Decode<'_> for DescribeShareGroupOffsetsRequestTopic

impl Decode<'_> for DescribeShareGroupOffsetsResponse

impl Decode<'_> for DescribeShareGroupOffsetsResponseGroup

impl Decode<'_> for DescribeShareGroupOffsetsResponsePartition

impl Decode<'_> for DescribeShareGroupOffsetsResponseTopic

impl Decode<'_> for DescribeTopicPartitionsRequest

impl Decode<'_> for DescribeTopicPartitionsResponse

impl Decode<'_> for DescribeTopicPartitionsResponsePartition

impl Decode<'_> for DescribeTopicPartitionsResponseTopic

impl Decode<'_> for DescribeTransactionsRequest

impl Decode<'_> for DescribeTransactionsResponse

impl Decode<'_> for DescribeUserScramCredentialsRequest

impl Decode<'_> for DescribeUserScramCredentialsResponse

impl Decode<'_> for DescribeUserScramCredentialsResult

impl Decode<'_> for DescribedDelegationToken

impl Decode<'_> for DescribedDelegationTokenRenewer

impl Decode<'_> for crabka_protocol::owned::consumer_group_describe_response::DescribedGroup

impl Decode<'_> for crabka_protocol::owned::describe_groups_response::DescribedGroup

impl Decode<'_> for crabka_protocol::owned::share_group_describe_response::DescribedGroup

impl Decode<'_> for crabka_protocol::owned::streams_group_describe_response::DescribedGroup

impl Decode<'_> for DescribedGroupMember

impl Decode<'_> for crabka_protocol::owned::assign_replicas_to_dirs_request::DirectoryData

impl Decode<'_> for crabka_protocol::owned::assign_replicas_to_dirs_response::DirectoryData

impl Decode<'_> for ElectLeadersRequest

impl Decode<'_> for ElectLeadersResponse

impl Decode<'_> for EndQuorumEpochRequest

impl Decode<'_> for EndQuorumEpochResponse

impl Decode<'_> for EndTransactionRecord

impl Decode<'_> for EndTxnMarker

impl Decode<'_> for EndTxnRequest

impl Decode<'_> for EndTxnResponse

impl Decode<'_> for crabka_protocol::owned::common::streams_group_describe_response::endpoint::Endpoint

impl Decode<'_> for crabka_protocol::owned::common::streams_group_heartbeat_request::endpoint::Endpoint

impl Decode<'_> for crabka_protocol::owned::common::streams_group_heartbeat_response::endpoint::Endpoint

impl Decode<'_> for crabka_protocol::owned::voters_record::Endpoint

impl Decode<'_> for EndpointToPartitions

impl Decode<'_> for crabka_protocol::owned::alter_client_quotas_request::EntityData

impl Decode<'_> for crabka_protocol::owned::alter_client_quotas_response::EntityData

impl Decode<'_> for crabka_protocol::owned::client_quota_record::EntityData

impl Decode<'_> for crabka_protocol::owned::describe_client_quotas_response::EntityData

impl Decode<'_> for crabka_protocol::owned::alter_client_quotas_request::EntryData

impl Decode<'_> for crabka_protocol::owned::alter_client_quotas_response::EntryData

impl Decode<'_> for crabka_protocol::owned::describe_client_quotas_response::EntryData

impl Decode<'_> for EnvelopeRequest

impl Decode<'_> for EnvelopeResponse

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_response::EpochEndOffset

impl Decode<'_> for crabka_protocol::owned::fetch_response::EpochEndOffset

impl Decode<'_> for crabka_protocol::owned::offset_for_leader_epoch_response::EpochEndOffset

impl Decode<'_> for ExpireDelegationTokenRequest

impl Decode<'_> for ExpireDelegationTokenResponse

impl Decode<'_> for crabka_protocol::owned::broker_registration_request::Feature

impl Decode<'_> for crabka_protocol::owned::controller_registration_request::Feature

impl Decode<'_> for FeatureLevelRecord

impl Decode<'_> for FeatureUpdateKey

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_request::FetchPartition

impl Decode<'_> for crabka_protocol::owned::fetch_request::FetchPartition

impl Decode<'_> for crabka_protocol::owned::share_fetch_request::FetchPartition

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_request::FetchRequest

impl Decode<'_> for crabka_protocol::owned::fetch_request::FetchRequest

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_response::FetchResponse

impl Decode<'_> for crabka_protocol::owned::fetch_response::FetchResponse

impl Decode<'_> for FetchSnapshotRequest

impl Decode<'_> for FetchSnapshotResponse

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_request::FetchTopic

impl Decode<'_> for crabka_protocol::owned::fetch_request::FetchTopic

impl Decode<'_> for crabka_protocol::owned::share_fetch_request::FetchTopic

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_response::FetchableTopicResponse

impl Decode<'_> for crabka_protocol::owned::fetch_response::FetchableTopicResponse

impl Decode<'_> for FinalizedFeatureKey

impl Decode<'_> for FindCoordinatorRequest

impl Decode<'_> for FindCoordinatorResponse

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_request::ForgottenTopic

impl Decode<'_> for crabka_protocol::owned::fetch_request::ForgottenTopic

impl Decode<'_> for crabka_protocol::owned::share_fetch_request::ForgottenTopic

impl Decode<'_> for GetReplicaLogInfoRequest

impl Decode<'_> for GetReplicaLogInfoResponse

impl Decode<'_> for GetTelemetrySubscriptionsRequest

impl Decode<'_> for GetTelemetrySubscriptionsResponse

impl Decode<'_> for HeartbeatRequest

impl Decode<'_> for HeartbeatResponse

impl Decode<'_> for IncrementalAlterConfigsRequest

impl Decode<'_> for IncrementalAlterConfigsResponse

impl Decode<'_> for InitProducerIdRequest

impl Decode<'_> for InitProducerIdResponse

impl Decode<'_> for InitializeShareGroupStateRequest

impl Decode<'_> for InitializeShareGroupStateResponse

impl Decode<'_> for InitializeStateData

impl Decode<'_> for InitializeStateResult

impl Decode<'_> for JoinGroupRequest

impl Decode<'_> for JoinGroupRequestProtocol

impl Decode<'_> for JoinGroupResponse

impl Decode<'_> for JoinGroupResponseMember

impl Decode<'_> for crabka_protocol::owned::update_raft_voter_request::KRaftVersionFeature

impl Decode<'_> for crabka_protocol::owned::voters_record::KRaftVersionFeature

impl Decode<'_> for KRaftVersionRecord

impl Decode<'_> for crabka_protocol::owned::common::streams_group_describe_response::key_value::KeyValue

impl Decode<'_> for crabka_protocol::owned::common::streams_group_heartbeat_request::key_value::KeyValue

impl Decode<'_> for LeaderChangeMessage

impl Decode<'_> for crabka_protocol::owned::begin_quorum_epoch_request::LeaderEndpoint

impl Decode<'_> for crabka_protocol::owned::end_quorum_epoch_request::LeaderEndpoint

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_response::LeaderIdAndEpoch

impl Decode<'_> for crabka_protocol::owned::fetch_response::LeaderIdAndEpoch

impl Decode<'_> for crabka_protocol::owned::fetch_snapshot_response::LeaderIdAndEpoch

impl Decode<'_> for crabka_protocol::owned::produce_response::LeaderIdAndEpoch

impl Decode<'_> for crabka_protocol::owned::share_acknowledge_response::LeaderIdAndEpoch

impl Decode<'_> for crabka_protocol::owned::share_fetch_response::LeaderIdAndEpoch

impl Decode<'_> for LeaveGroupRequest

impl Decode<'_> for LeaveGroupResponse

impl Decode<'_> for ListConfigResourcesRequest

impl Decode<'_> for ListConfigResourcesResponse

impl Decode<'_> for ListGroupsRequest

impl Decode<'_> for ListGroupsResponse

impl Decode<'_> for ListOffsetsPartition

impl Decode<'_> for ListOffsetsPartitionResponse

impl Decode<'_> for ListOffsetsRequest

impl Decode<'_> for ListOffsetsResponse

impl Decode<'_> for ListOffsetsTopic

impl Decode<'_> for ListOffsetsTopicResponse

impl Decode<'_> for ListPartitionReassignmentsRequest

impl Decode<'_> for ListPartitionReassignmentsResponse

impl Decode<'_> for ListPartitionReassignmentsTopics

impl Decode<'_> for ListTransactionsRequest

impl Decode<'_> for ListTransactionsResponse

impl Decode<'_> for ListedGroup

impl Decode<'_> for crabka_protocol::owned::add_raft_voter_request::Listener

impl Decode<'_> for crabka_protocol::owned::broker_registration_request::Listener

impl Decode<'_> for crabka_protocol::owned::controller_registration_request::Listener

impl Decode<'_> for crabka_protocol::owned::describe_quorum_response::Listener

impl Decode<'_> for crabka_protocol::owned::update_raft_voter_request::Listener

impl Decode<'_> for crabka_protocol::owned::consumer_group_describe_response::Member

impl Decode<'_> for crabka_protocol::owned::share_group_describe_response::Member

impl Decode<'_> for crabka_protocol::owned::streams_group_describe_response::Member

impl Decode<'_> for MemberIdentity

impl Decode<'_> for MemberResponse

impl Decode<'_> for MetadataRequest

impl Decode<'_> for MetadataRequestTopic

impl Decode<'_> for MetadataResponse

impl Decode<'_> for MetadataResponseBroker

impl Decode<'_> for MetadataResponsePartition

impl Decode<'_> for MetadataResponseTopic

impl Decode<'_> for NoOpRecord

impl Decode<'_> for Node

impl Decode<'_> for crabka_protocol::owned::begin_quorum_epoch_response::NodeEndpoint

impl Decode<'_> for crabka_protocol::owned::end_quorum_epoch_response::NodeEndpoint

impl Decode<'_> for crabka_protocol::owned::fetch_response::NodeEndpoint

impl Decode<'_> for crabka_protocol::owned::fetch_snapshot_response::NodeEndpoint

impl Decode<'_> for crabka_protocol::owned::produce_response::NodeEndpoint

impl Decode<'_> for crabka_protocol::owned::share_acknowledge_response::NodeEndpoint

impl Decode<'_> for crabka_protocol::owned::share_fetch_response::NodeEndpoint

impl Decode<'_> for crabka_protocol::owned::vote_response::NodeEndpoint

impl Decode<'_> for OffsetCommitRequest

impl Decode<'_> for OffsetCommitRequestPartition

impl Decode<'_> for OffsetCommitRequestTopic

impl Decode<'_> for OffsetCommitResponse

impl Decode<'_> for OffsetCommitResponsePartition

impl Decode<'_> for OffsetCommitResponseTopic

impl Decode<'_> for OffsetDeleteRequest

impl Decode<'_> for OffsetDeleteRequestPartition

impl Decode<'_> for OffsetDeleteRequestTopic

impl Decode<'_> for OffsetDeleteResponse

impl Decode<'_> for OffsetDeleteResponsePartition

impl Decode<'_> for OffsetDeleteResponseTopic

impl Decode<'_> for OffsetFetchRequest

impl Decode<'_> for OffsetFetchRequestGroup

impl Decode<'_> for OffsetFetchRequestTopic

impl Decode<'_> for OffsetFetchRequestTopics

impl Decode<'_> for OffsetFetchResponse

impl Decode<'_> for OffsetFetchResponseGroup

impl Decode<'_> for OffsetFetchResponsePartition

impl Decode<'_> for OffsetFetchResponsePartitions

impl Decode<'_> for OffsetFetchResponseTopic

impl Decode<'_> for OffsetFetchResponseTopics

impl Decode<'_> for OffsetForLeaderEpochRequest

impl Decode<'_> for OffsetForLeaderEpochResponse

impl Decode<'_> for OffsetForLeaderPartition

impl Decode<'_> for OffsetForLeaderTopic

impl Decode<'_> for OffsetForLeaderTopicResult

impl Decode<'_> for OngoingPartitionReassignment

impl Decode<'_> for OngoingTopicReassignment

impl Decode<'_> for OpData

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_response::PartitionData

impl Decode<'_> for crabka_protocol::owned::alter_partition_request::PartitionData

impl Decode<'_> for crabka_protocol::owned::alter_partition_response::PartitionData

impl Decode<'_> for crabka_protocol::owned::assign_replicas_to_dirs_request::PartitionData

impl Decode<'_> for crabka_protocol::owned::assign_replicas_to_dirs_response::PartitionData

impl Decode<'_> for crabka_protocol::owned::begin_quorum_epoch_request::PartitionData

impl Decode<'_> for crabka_protocol::owned::begin_quorum_epoch_response::PartitionData

impl Decode<'_> for crabka_protocol::owned::delete_share_group_state_request::PartitionData

impl Decode<'_> for crabka_protocol::owned::describe_quorum_request::PartitionData

impl Decode<'_> for crabka_protocol::owned::describe_quorum_response::PartitionData

impl Decode<'_> for crabka_protocol::owned::end_quorum_epoch_request::PartitionData

impl Decode<'_> for crabka_protocol::owned::end_quorum_epoch_response::PartitionData

impl Decode<'_> for crabka_protocol::owned::fetch_response::PartitionData

impl Decode<'_> for crabka_protocol::owned::initialize_share_group_state_request::PartitionData

impl Decode<'_> for crabka_protocol::owned::read_share_group_state_request::PartitionData

impl Decode<'_> for crabka_protocol::owned::read_share_group_state_summary_request::PartitionData

impl Decode<'_> for crabka_protocol::owned::share_acknowledge_response::PartitionData

impl Decode<'_> for crabka_protocol::owned::share_fetch_response::PartitionData

impl Decode<'_> for crabka_protocol::owned::vote_request::PartitionData

impl Decode<'_> for crabka_protocol::owned::vote_response::PartitionData

impl Decode<'_> for crabka_protocol::owned::write_share_group_state_request::PartitionData

impl Decode<'_> for PartitionLogInfo

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::produce_request::PartitionProduceData

impl Decode<'_> for crabka_protocol::owned::produce_request::PartitionProduceData

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::produce_response::PartitionProduceResponse

impl Decode<'_> for crabka_protocol::owned::produce_response::PartitionProduceResponse

impl Decode<'_> for PartitionRecord

impl Decode<'_> for PartitionResponse

impl Decode<'_> for crabka_protocol::owned::delete_share_group_state_response::PartitionResult

impl Decode<'_> for crabka_protocol::owned::elect_leaders_response::PartitionResult

impl Decode<'_> for crabka_protocol::owned::initialize_share_group_state_response::PartitionResult

impl Decode<'_> for crabka_protocol::owned::read_share_group_state_response::PartitionResult

impl Decode<'_> for crabka_protocol::owned::read_share_group_state_summary_response::PartitionResult

impl Decode<'_> for crabka_protocol::owned::write_share_group_state_response::PartitionResult

impl Decode<'_> for crabka_protocol::owned::fetch_snapshot_request::PartitionSnapshot

impl Decode<'_> for crabka_protocol::owned::fetch_snapshot_response::PartitionSnapshot

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::produce_request::ProduceRequest

impl Decode<'_> for crabka_protocol::owned::produce_request::ProduceRequest

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::produce_response::ProduceResponse

impl Decode<'_> for crabka_protocol::owned::produce_response::ProduceResponse

impl Decode<'_> for ProducerState

impl Decode<'_> for PushTelemetryRequest

impl Decode<'_> for PushTelemetryResponse

impl Decode<'_> for ReadShareGroupStateRequest

impl Decode<'_> for ReadShareGroupStateResponse

impl Decode<'_> for ReadShareGroupStateSummaryRequest

impl Decode<'_> for ReadShareGroupStateSummaryResponse

impl Decode<'_> for ReadStateData

impl Decode<'_> for ReadStateResult

impl Decode<'_> for ReadStateSummaryData

impl Decode<'_> for ReadStateSummaryResult

impl Decode<'_> for ReassignablePartition

impl Decode<'_> for ReassignablePartitionResponse

impl Decode<'_> for ReassignableTopic

impl Decode<'_> for ReassignableTopicResponse

impl Decode<'_> for RecordBatch

impl Decode<'_> for RecordsPayload

impl Decode<'_> for RegisterBrokerRecord

impl Decode<'_> for RegisterControllerRecord

impl Decode<'_> for RemoveAccessControlEntryRecord

impl Decode<'_> for RemoveDelegationTokenRecord

impl Decode<'_> for RemoveRaftVoterRequest

impl Decode<'_> for RemoveRaftVoterResponse

impl Decode<'_> for RemoveTopicRecord

impl Decode<'_> for RemoveUserScramCredentialRecord

impl Decode<'_> for RenewDelegationTokenRequest

impl Decode<'_> for RenewDelegationTokenResponse

impl Decode<'_> for ReplicaElectionResult

impl Decode<'_> for ReplicaInfo

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_request::ReplicaState

impl Decode<'_> for crabka_protocol::owned::common::describe_quorum_response::replica_state::ReplicaState

impl Decode<'_> for crabka_protocol::owned::fetch_request::ReplicaState

impl Decode<'_> for RequestHeader

impl Decode<'_> for ResponseHeader

impl Decode<'_> for SaslAuthenticateRequest

impl Decode<'_> for SaslAuthenticateResponse

impl Decode<'_> for SaslHandshakeRequest

impl Decode<'_> for SaslHandshakeResponse

impl Decode<'_> for ScramCredentialDeletion

impl Decode<'_> for ScramCredentialUpsertion

impl Decode<'_> for ShareAcknowledgeRequest

impl Decode<'_> for ShareAcknowledgeResponse

impl Decode<'_> for ShareAcknowledgeTopicResponse

impl Decode<'_> for ShareFetchRequest

impl Decode<'_> for ShareFetchResponse

impl Decode<'_> for ShareFetchableTopicResponse

impl Decode<'_> for ShareGroupDescribeRequest

impl Decode<'_> for ShareGroupDescribeResponse

impl Decode<'_> for ShareGroupHeartbeatRequest

impl Decode<'_> for ShareGroupHeartbeatResponse

impl Decode<'_> for SnapshotFooterRecord

impl Decode<'_> for SnapshotHeaderRecord

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::fetch_response::SnapshotId

impl Decode<'_> for crabka_protocol::owned::fetch_response::SnapshotId

impl Decode<'_> for crabka_protocol::owned::fetch_snapshot_request::SnapshotId

impl Decode<'_> for crabka_protocol::owned::fetch_snapshot_response::SnapshotId

impl Decode<'_> for crabka_protocol::owned::read_share_group_state_response::StateBatch

impl Decode<'_> for crabka_protocol::owned::write_share_group_state_request::StateBatch

impl Decode<'_> for Status

impl Decode<'_> for StreamsGroupDescribeRequest

impl Decode<'_> for StreamsGroupDescribeResponse

impl Decode<'_> for StreamsGroupHeartbeatRequest

impl Decode<'_> for StreamsGroupHeartbeatResponse

impl Decode<'_> for crabka_protocol::owned::streams_group_describe_response::Subtopology

impl Decode<'_> for crabka_protocol::owned::streams_group_heartbeat_request::Subtopology

impl Decode<'_> for SupportedFeatureKey

impl Decode<'_> for SyncGroupRequest

impl Decode<'_> for SyncGroupRequestAssignment

impl Decode<'_> for SyncGroupResponse

impl Decode<'_> for crabka_protocol::owned::common::streams_group_describe_response::task_ids::TaskIds

impl Decode<'_> for crabka_protocol::owned::common::streams_group_heartbeat_request::task_ids::TaskIds

impl Decode<'_> for crabka_protocol::owned::common::streams_group_heartbeat_response::task_ids::TaskIds

impl Decode<'_> for crabka_protocol::owned::common::streams_group_describe_response::task_offset::TaskOffset

impl Decode<'_> for crabka_protocol::owned::common::streams_group_heartbeat_request::task_offset::TaskOffset

impl Decode<'_> for crabka_protocol::owned::alter_partition_request::TopicData

impl Decode<'_> for crabka_protocol::owned::alter_partition_response::TopicData

impl Decode<'_> for crabka_protocol::owned::assign_replicas_to_dirs_request::TopicData

impl Decode<'_> for crabka_protocol::owned::assign_replicas_to_dirs_response::TopicData

impl Decode<'_> for crabka_protocol::owned::begin_quorum_epoch_request::TopicData

impl Decode<'_> for crabka_protocol::owned::begin_quorum_epoch_response::TopicData

impl Decode<'_> for crabka_protocol::owned::describe_quorum_request::TopicData

impl Decode<'_> for crabka_protocol::owned::describe_quorum_response::TopicData

impl Decode<'_> for crabka_protocol::owned::describe_transactions_response::TopicData

impl Decode<'_> for crabka_protocol::owned::end_quorum_epoch_request::TopicData

impl Decode<'_> for crabka_protocol::owned::end_quorum_epoch_response::TopicData

impl Decode<'_> for crabka_protocol::owned::vote_request::TopicData

impl Decode<'_> for crabka_protocol::owned::vote_response::TopicData

impl Decode<'_> for crabka_protocol::owned::common::streams_group_describe_response::topic_info::TopicInfo

impl Decode<'_> for crabka_protocol::owned::common::streams_group_heartbeat_request::topic_info::TopicInfo

impl Decode<'_> for crabka_protocol::owned::common::streams_group_heartbeat_response::topic_partition::TopicPartition

impl Decode<'_> for crabka_protocol::owned::consumer_protocol_assignment::TopicPartition

impl Decode<'_> for crabka_protocol::owned::consumer_protocol_subscription::TopicPartition

impl Decode<'_> for TopicPartitionLogInfo

impl Decode<'_> for crabka_protocol::owned::common::consumer_group_describe_response::topic_partitions::TopicPartitions

impl Decode<'_> for crabka_protocol::owned::common::consumer_group_heartbeat_response::topic_partitions::TopicPartitions

impl Decode<'_> for crabka_protocol::owned::common::share_group_describe_response::topic_partitions::TopicPartitions

impl Decode<'_> for crabka_protocol::owned::common::share_group_heartbeat_response::topic_partitions::TopicPartitions

impl Decode<'_> for crabka_protocol::owned::consumer_group_heartbeat_request::TopicPartitions

impl Decode<'_> for crabka_protocol::owned::elect_leaders_request::TopicPartitions

impl Decode<'_> for crabka_protocol::owned::get_replica_log_info_request::TopicPartitions

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::produce_request::TopicProduceData

impl Decode<'_> for crabka_protocol::owned::produce_request::TopicProduceData

impl Decode<'_> for crabka_protocol::kafka_3_6_2::owned::produce_response::TopicProduceResponse

impl Decode<'_> for crabka_protocol::owned::produce_response::TopicProduceResponse

impl Decode<'_> for TopicRecord

impl Decode<'_> for crabka_protocol::owned::describe_producers_request::TopicRequest

impl Decode<'_> for crabka_protocol::owned::describe_topic_partitions_request::TopicRequest

impl Decode<'_> for TopicResponse

impl Decode<'_> for crabka_protocol::owned::fetch_snapshot_request::TopicSnapshot

impl Decode<'_> for crabka_protocol::owned::fetch_snapshot_response::TopicSnapshot

impl Decode<'_> for crabka_protocol::owned::streams_group_describe_response::Topology

impl Decode<'_> for crabka_protocol::owned::streams_group_heartbeat_request::Topology

impl Decode<'_> for crabka_protocol::owned::describe_transactions_response::TransactionState

impl Decode<'_> for crabka_protocol::owned::list_transactions_response::TransactionState

impl Decode<'_> for TxnOffsetCommitRequest

impl Decode<'_> for TxnOffsetCommitRequestPartition

impl Decode<'_> for TxnOffsetCommitRequestTopic

impl Decode<'_> for TxnOffsetCommitResponse

impl Decode<'_> for TxnOffsetCommitResponsePartition

impl Decode<'_> for TxnOffsetCommitResponseTopic

impl Decode<'_> for UnregisterBrokerRecord

impl Decode<'_> for UnregisterBrokerRequest

impl Decode<'_> for UnregisterBrokerResponse

impl Decode<'_> for UpdatableFeatureResult

impl Decode<'_> for UpdateFeaturesRequest

impl Decode<'_> for UpdateFeaturesResponse

impl Decode<'_> for UpdateRaftVoterRequest

impl Decode<'_> for UpdateRaftVoterResponse

impl Decode<'_> for UserName

impl Decode<'_> for UserScramCredentialRecord

impl Decode<'_> for ValueData

impl Decode<'_> for VoteRequest

impl Decode<'_> for VoteResponse

impl Decode<'_> for crabka_protocol::owned::common::leader_change_message::voter::Voter

impl Decode<'_> for crabka_protocol::owned::voters_record::Voter

impl Decode<'_> for VotersRecord

impl Decode<'_> for WritableTxnMarker

impl Decode<'_> for WritableTxnMarkerPartitionResult

impl Decode<'_> for WritableTxnMarkerResult

impl Decode<'_> for WritableTxnMarkerTopic

impl Decode<'_> for WritableTxnMarkerTopicResult

impl Decode<'_> for WriteShareGroupStateRequest

impl Decode<'_> for WriteShareGroupStateResponse

impl Decode<'_> for WriteStateData

impl Decode<'_> for WriteStateResult

impl Decode<'_> for WriteTxnMarkersRequest

impl Decode<'_> for WriteTxnMarkersResponse