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, because 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>

Errors

Returns the underlying protocol error when input is truncated, contains an invalid length or tag, or cannot be encoded for the selected version.

Dyn Compatibility

This trait is not dyn compatible.

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

Implementors

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

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

impl Decode<'_> for AccessControlEntryRecord

impl Decode<'_> for AcknowledgePartition

impl Decode<'_> for AcknowledgeTopic

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

impl Decode<'_> for krabka_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 AlterBarrierGroupResult

impl Decode<'_> for AlterBarrierGroupsRequest

impl Decode<'_> for AlterBarrierGroupsResponse

impl Decode<'_> for AlterClientQuotasRequest

impl Decode<'_> for AlterClientQuotasResponse

impl Decode<'_> for AlterConfigsRequest

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

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

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

impl Decode<'_> for krabka_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 AlterableBarrierGroup

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

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

impl Decode<'_> for ApiVersion

impl Decode<'_> for ApiVersionsRequest

impl Decode<'_> for ApiVersionsResponse

impl Decode<'_> for ApproveBreakGlassRequest

impl Decode<'_> for ApproveBreakGlassResponse

impl Decode<'_> for AssignReplicasToDirsRequest

impl Decode<'_> for AssignReplicasToDirsResponse

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

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

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

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

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

impl Decode<'_> for BarrierCut

impl Decode<'_> for BarrierCutPartition

impl Decode<'_> for BarrierCutTopic

impl Decode<'_> for BarrierMissingPartition

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

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

impl Decode<'_> for BeginQuorumEpochRequest

impl Decode<'_> for BeginQuorumEpochResponse

impl Decode<'_> for BeginTransactionRecord

impl Decode<'_> for BreakGlassApproval

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 krabka_protocol::owned::describe_topic_partitions_request::Cursor

impl Decode<'_> for krabka_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 DescribeBarrierGroupsRequest

impl Decode<'_> for DescribeBarrierGroupsResponse

impl Decode<'_> for DescribeBreakGlassRequest

impl Decode<'_> for DescribeBreakGlassResponse

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 DescribeTopicFreezesRequest

impl Decode<'_> for DescribeTopicFreezesResponse

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 DescribedBarrierGroup

impl Decode<'_> for DescribedBreakGlassProposal

impl Decode<'_> for DescribedDelegationToken

impl Decode<'_> for DescribedDelegationTokenRenewer

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

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

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

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

impl Decode<'_> for DescribedGroupMember

impl Decode<'_> for DescribedTopicFreeze

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

impl Decode<'_> for krabka_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 krabka_protocol::owned::common::streams_group_describe_response::endpoint::Endpoint

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

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

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

impl Decode<'_> for EndpointToPartitions

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

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

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

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

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

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

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

impl Decode<'_> for EnvelopeRequest

impl Decode<'_> for EnvelopeResponse

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

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

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

impl Decode<'_> for ExpireDelegationTokenRequest

impl Decode<'_> for ExpireDelegationTokenResponse

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

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

impl Decode<'_> for FeatureLevelRecord

impl Decode<'_> for FeatureUpdateKey

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

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

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

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

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

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

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

impl Decode<'_> for FetchSnapshotRequest

impl Decode<'_> for FetchSnapshotResponse

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

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

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

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

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

impl Decode<'_> for FinalizedFeatureKey

impl Decode<'_> for FindCoordinatorRequest

impl Decode<'_> for FindCoordinatorResponse

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

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

impl Decode<'_> for krabka_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 krabka_protocol::owned::update_raft_voter_request::KRaftVersionFeature

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

impl Decode<'_> for KRaftVersionRecord

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

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

impl Decode<'_> for LeaderChangeMessage

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

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

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

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

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

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

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

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

impl Decode<'_> for LeaveGroupRequest

impl Decode<'_> for LeaveGroupResponse

impl Decode<'_> for ListBarrierCutsRequest

impl Decode<'_> for ListBarrierCutsResponse

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 krabka_protocol::owned::add_raft_voter_request::Listener

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

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

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

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

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

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

impl Decode<'_> for krabka_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 krabka_protocol::owned::begin_quorum_epoch_response::NodeEndpoint

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

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

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

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

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

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

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

impl Decode<'_> for OffsetCommitKey

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 OffsetCommitValue

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 PartitionChangeRecord

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

impl Decode<'_> for PartitionLogInfo

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

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

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

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

impl Decode<'_> for PartitionRecord

impl Decode<'_> for PartitionResponse

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

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

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

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

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

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

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

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

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

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

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

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

impl Decode<'_> for ProducerIdsRecord

impl Decode<'_> for ProducerState

impl Decode<'_> for ProposeBreakGlassRequest

impl Decode<'_> for ProposeBreakGlassResponse

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 krabka_protocol::owned::remote_log_segment_metadata_record::RemoteLogSegmentIdEntry

impl Decode<'_> for krabka_protocol::owned::remote_log_segment_metadata_update_record::RemoteLogSegmentIdEntry

impl Decode<'_> for RemoteLogSegmentMetadataRecord

impl Decode<'_> for RemoteLogSegmentMetadataSnapshotRecord

impl Decode<'_> for RemoteLogSegmentMetadataUpdateRecord

impl Decode<'_> for RemotePartitionDeleteMetadataRecord

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 krabka_protocol::kafka_3_6_2::owned::fetch_request::ReplicaState

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

impl Decode<'_> for krabka_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 krabka_protocol::owned::remote_log_segment_metadata_record::SegmentLeaderEpochEntry

impl Decode<'_> for krabka_protocol::owned::remote_log_segment_metadata_snapshot_record::SegmentLeaderEpochEntry

impl Decode<'_> for SetTopicFreezeRequest

impl Decode<'_> for SetTopicFreezeResponse

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 krabka_protocol::kafka_3_6_2::owned::fetch_response::SnapshotId

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

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

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

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

impl Decode<'_> for krabka_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 StreamsGroupTopologyDescriptionUpdateRequest

impl Decode<'_> for StreamsGroupTopologyDescriptionUpdateResponse

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

impl Decode<'_> for krabka_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 krabka_protocol::owned::common::streams_group_describe_response::task_ids::TaskIds

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

impl Decode<'_> for krabka_protocol::owned::remote_log_segment_metadata_record::TopicIdPartitionEntry

impl Decode<'_> for krabka_protocol::owned::remote_log_segment_metadata_update_record::TopicIdPartitionEntry

impl Decode<'_> for krabka_protocol::owned::remote_partition_delete_metadata_record::TopicIdPartitionEntry

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

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

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

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

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

impl Decode<'_> for TopicPartitionLogInfo

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

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

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

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

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

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

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

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

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

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

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

impl Decode<'_> for TopicRecord

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

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

impl Decode<'_> for TopicResponse

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

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

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

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

impl Decode<'_> for krabka_protocol::owned::common::streams_group_describe_response::topology_description::TopologyDescription

impl Decode<'_> for krabka_protocol::owned::common::streams_group_topology_description_update_request::topology_description::TopologyDescription

impl Decode<'_> for krabka_protocol::owned::common::streams_group_describe_response::topology_description_global_store::TopologyDescriptionGlobalStore

impl Decode<'_> for krabka_protocol::owned::common::streams_group_topology_description_update_request::topology_description_global_store::TopologyDescriptionGlobalStore

impl Decode<'_> for krabka_protocol::owned::common::streams_group_describe_response::topology_description_node::TopologyDescriptionNode

impl Decode<'_> for krabka_protocol::owned::common::streams_group_topology_description_update_request::topology_description_node::TopologyDescriptionNode

impl Decode<'_> for krabka_protocol::owned::common::streams_group_describe_response::topology_description_subtopology::TopologyDescriptionSubtopology

impl Decode<'_> for krabka_protocol::owned::common::streams_group_topology_description_update_request::topology_description_subtopology::TopologyDescriptionSubtopology

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

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

impl Decode<'_> for TriggerBarrierRequest

impl Decode<'_> for TriggerBarrierResponse

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 UnregisterControllerRecord

impl Decode<'_> for UnregisterControllerRequest

impl Decode<'_> for UnregisterControllerResponse

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 krabka_protocol::owned::common::leader_change_message::voter::Voter

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

impl Decode<'_> for VotersRecord

impl Decode<'_> for WritableBarrierPartition

impl Decode<'_> for WritableBarrierTopic

impl Decode<'_> for WritableTxnMarker

impl Decode<'_> for WritableTxnMarkerPartitionResult

impl Decode<'_> for WritableTxnMarkerResult

impl Decode<'_> for WritableTxnMarkerTopic

impl Decode<'_> for WritableTxnMarkerTopicResult

impl Decode<'_> for WriteBarrierMarkersRequest

impl Decode<'_> for WriteBarrierMarkersResponse

impl Decode<'_> for WriteShareGroupStateRequest

impl Decode<'_> for WriteShareGroupStateResponse

impl Decode<'_> for WriteStateData

impl Decode<'_> for WriteStateResult

impl Decode<'_> for WriteTxnMarkersRequest

impl Decode<'_> for WriteTxnMarkersResponse

impl Decode<'_> for WrittenBarrierPartition

impl Decode<'_> for WrittenBarrierTopic