pub trait Encodable: Sized {
    // Required methods
    fn encode<B: ByteBufMut>(
        &self,
        buf: &mut B,
        version: i16
    ) -> Result<(), EncodeError>;
    fn compute_size(&self, version: i16) -> Result<usize, EncodeError>;
}
Expand description

An encodable message.

Required Methods§

source

fn encode<B: ByteBufMut>( &self, buf: &mut B, version: i16 ) -> Result<(), EncodeError>

Encode the message into the target buffer.

source

fn compute_size(&self, version: i16) -> Result<usize, EncodeError>

Compute the total size of the message when encoded.

Object Safety§

This trait is not object safe.

Implementors§

source§

impl Encodable for AddOffsetsToTxnRequest

source§

impl Encodable for AddOffsetsToTxnResponse

source§

impl Encodable for AddPartitionsToTxnRequest

source§

impl Encodable for AddPartitionsToTxnResponse

source§

impl Encodable for AllocateProducerIdsRequest

source§

impl Encodable for AllocateProducerIdsResponse

source§

impl Encodable for AlterClientQuotasRequest

source§

impl Encodable for kafka_protocol::messages::alter_client_quotas_request::EntityData

source§

impl Encodable for kafka_protocol::messages::alter_client_quotas_request::EntryData

source§

impl Encodable for OpData

source§

impl Encodable for AlterClientQuotasResponse

source§

impl Encodable for kafka_protocol::messages::alter_client_quotas_response::EntityData

source§

impl Encodable for kafka_protocol::messages::alter_client_quotas_response::EntryData

source§

impl Encodable for AlterConfigsRequest

source§

impl Encodable for kafka_protocol::messages::alter_configs_request::AlterConfigsResource

source§

impl Encodable for kafka_protocol::messages::alter_configs_response::AlterConfigsResourceResponse

source§

impl Encodable for AlterConfigsResponse

source§

impl Encodable for AlterPartitionReassignmentsRequest

source§

impl Encodable for ReassignablePartition

source§

impl Encodable for ReassignableTopic

source§

impl Encodable for AlterPartitionReassignmentsResponse

source§

impl Encodable for ReassignablePartitionResponse

source§

impl Encodable for ReassignableTopicResponse

source§

impl Encodable for AlterPartitionRequest

source§

impl Encodable for BrokerState

source§

impl Encodable for kafka_protocol::messages::alter_partition_request::PartitionData

source§

impl Encodable for kafka_protocol::messages::alter_partition_request::TopicData

source§

impl Encodable for AlterPartitionResponse

source§

impl Encodable for kafka_protocol::messages::alter_partition_response::PartitionData

source§

impl Encodable for kafka_protocol::messages::alter_partition_response::TopicData

source§

impl Encodable for AlterReplicaLogDirsRequest

source§

impl Encodable for AlterReplicaLogDirPartitionResult

source§

impl Encodable for AlterReplicaLogDirTopicResult

source§

impl Encodable for AlterReplicaLogDirsResponse

source§

impl Encodable for AlterUserScramCredentialsRequest

source§

impl Encodable for ScramCredentialDeletion

source§

impl Encodable for ScramCredentialUpsertion

source§

impl Encodable for AlterUserScramCredentialsResponse

source§

impl Encodable for AlterUserScramCredentialsResult

source§

impl Encodable for ApiVersionsRequest

source§

impl Encodable for ApiVersionsResponse

source§

impl Encodable for AssignReplicasToDirsRequest

source§

impl Encodable for kafka_protocol::messages::assign_replicas_to_dirs_request::DirectoryData

source§

impl Encodable for kafka_protocol::messages::assign_replicas_to_dirs_request::PartitionData

source§

impl Encodable for kafka_protocol::messages::assign_replicas_to_dirs_request::TopicData

source§

impl Encodable for AssignReplicasToDirsResponse

source§

impl Encodable for kafka_protocol::messages::assign_replicas_to_dirs_response::DirectoryData

source§

impl Encodable for kafka_protocol::messages::assign_replicas_to_dirs_response::PartitionData

source§

impl Encodable for kafka_protocol::messages::assign_replicas_to_dirs_response::TopicData

source§

impl Encodable for BeginQuorumEpochRequest

source§

impl Encodable for kafka_protocol::messages::begin_quorum_epoch_request::PartitionData

source§

impl Encodable for kafka_protocol::messages::begin_quorum_epoch_request::TopicData

source§

impl Encodable for BeginQuorumEpochResponse

source§

impl Encodable for kafka_protocol::messages::begin_quorum_epoch_response::PartitionData

source§

impl Encodable for kafka_protocol::messages::begin_quorum_epoch_response::TopicData

source§

impl Encodable for BrokerHeartbeatRequest

source§

impl Encodable for BrokerHeartbeatResponse

source§

impl Encodable for BrokerRegistrationRequest

source§

impl Encodable for BrokerRegistrationResponse

source§

impl Encodable for ConsumerGroupHeartbeatRequest

source§

impl Encodable for kafka_protocol::messages::consumer_group_heartbeat_request::TopicPartitions

source§

impl Encodable for Assignment

source§

impl Encodable for ConsumerGroupHeartbeatResponse

source§

impl Encodable for kafka_protocol::messages::consumer_group_heartbeat_response::TopicPartitions

source§

impl Encodable for ConsumerProtocolAssignment

source§

impl Encodable for ConsumerProtocolSubscription

source§

impl Encodable for ControlledShutdownRequest

source§

impl Encodable for ControlledShutdownResponse

source§

impl Encodable for RemainingPartition

source§

impl Encodable for ControllerRegistrationRequest

source§

impl Encodable for ControllerRegistrationResponse

source§

impl Encodable for AclCreation

source§

impl Encodable for CreateAclsRequest

source§

impl Encodable for AclCreationResult

source§

impl Encodable for CreateAclsResponse

source§

impl Encodable for CreatableRenewers

source§

impl Encodable for CreateDelegationTokenRequest

source§

impl Encodable for CreateDelegationTokenResponse

source§

impl Encodable for CreatePartitionsAssignment

source§

impl Encodable for CreatePartitionsRequest

source§

impl Encodable for CreatePartitionsResponse

source§

impl Encodable for CreatePartitionsTopicResult

source§

impl Encodable for CreateTopicsRequest

source§

impl Encodable for CreatableTopicConfigs

source§

impl Encodable for CreateTopicsResponse

source§

impl Encodable for DefaultPrincipalData

source§

impl Encodable for DeleteAclsFilter

source§

impl Encodable for DeleteAclsRequest

source§

impl Encodable for DeleteAclsFilterResult

source§

impl Encodable for DeleteAclsMatchingAcl

source§

impl Encodable for DeleteAclsResponse

source§

impl Encodable for DeleteGroupsRequest

source§

impl Encodable for DeleteGroupsResponse

source§

impl Encodable for DeleteRecordsPartition

source§

impl Encodable for DeleteRecordsRequest

source§

impl Encodable for DeleteRecordsTopic

source§

impl Encodable for DeleteRecordsResponse

source§

impl Encodable for DeleteTopicState

source§

impl Encodable for DeleteTopicsRequest

source§

impl Encodable for DeleteTopicsResponse

source§

impl Encodable for DescribeAclsRequest

source§

impl Encodable for AclDescription

source§

impl Encodable for DescribeAclsResource

source§

impl Encodable for DescribeAclsResponse

source§

impl Encodable for ComponentData

source§

impl Encodable for DescribeClientQuotasRequest

source§

impl Encodable for DescribeClientQuotasResponse

source§

impl Encodable for kafka_protocol::messages::describe_client_quotas_response::EntityData

source§

impl Encodable for kafka_protocol::messages::describe_client_quotas_response::EntryData

source§

impl Encodable for ValueData

source§

impl Encodable for DescribeClusterRequest

source§

impl Encodable for DescribeClusterResponse

source§

impl Encodable for DescribeConfigsRequest

source§

impl Encodable for DescribeConfigsResource

source§

impl Encodable for DescribeConfigsResourceResult

source§

impl Encodable for DescribeConfigsResponse

source§

impl Encodable for DescribeConfigsResult

source§

impl Encodable for DescribeConfigsSynonym

source§

impl Encodable for DescribeDelegationTokenOwner

source§

impl Encodable for DescribeDelegationTokenRequest

source§

impl Encodable for DescribeDelegationTokenResponse

source§

impl Encodable for DescribedDelegationToken

source§

impl Encodable for DescribedDelegationTokenRenewer

source§

impl Encodable for DescribeGroupsRequest

source§

impl Encodable for DescribeGroupsResponse

source§

impl Encodable for DescribedGroup

source§

impl Encodable for DescribedGroupMember

source§

impl Encodable for DescribeLogDirsRequest

source§

impl Encodable for DescribeLogDirsPartition

source§

impl Encodable for DescribeLogDirsResponse

source§

impl Encodable for DescribeLogDirsResult

source§

impl Encodable for DescribeLogDirsTopic

source§

impl Encodable for DescribeProducersRequest

source§

impl Encodable for TopicRequest

source§

impl Encodable for DescribeProducersResponse

source§

impl Encodable for PartitionResponse

source§

impl Encodable for ProducerState

source§

impl Encodable for TopicResponse

source§

impl Encodable for DescribeQuorumRequest

source§

impl Encodable for kafka_protocol::messages::describe_quorum_request::PartitionData

source§

impl Encodable for kafka_protocol::messages::describe_quorum_request::TopicData

source§

impl Encodable for DescribeQuorumResponse

source§

impl Encodable for kafka_protocol::messages::describe_quorum_response::PartitionData

source§

impl Encodable for kafka_protocol::messages::describe_quorum_response::ReplicaState

source§

impl Encodable for kafka_protocol::messages::describe_quorum_response::TopicData

source§

impl Encodable for DescribeTransactionsRequest

source§

impl Encodable for DescribeTransactionsResponse

source§

impl Encodable for kafka_protocol::messages::describe_transactions_response::TransactionState

source§

impl Encodable for DescribeUserScramCredentialsRequest

source§

impl Encodable for UserName

source§

impl Encodable for CredentialInfo

source§

impl Encodable for DescribeUserScramCredentialsResponse

source§

impl Encodable for DescribeUserScramCredentialsResult

source§

impl Encodable for ElectLeadersRequest

source§

impl Encodable for ElectLeadersResponse

source§

impl Encodable for PartitionResult

source§

impl Encodable for ReplicaElectionResult

source§

impl Encodable for EndQuorumEpochRequest

source§

impl Encodable for kafka_protocol::messages::end_quorum_epoch_request::PartitionData

source§

impl Encodable for kafka_protocol::messages::end_quorum_epoch_request::TopicData

source§

impl Encodable for EndQuorumEpochResponse

source§

impl Encodable for kafka_protocol::messages::end_quorum_epoch_response::PartitionData

source§

impl Encodable for kafka_protocol::messages::end_quorum_epoch_response::TopicData

source§

impl Encodable for EndTxnRequest

source§

impl Encodable for EndTxnResponse

source§

impl Encodable for EnvelopeRequest

source§

impl Encodable for EnvelopeResponse

source§

impl Encodable for ExpireDelegationTokenRequest

source§

impl Encodable for ExpireDelegationTokenResponse

source§

impl Encodable for FetchPartition

source§

impl Encodable for FetchRequest

source§

impl Encodable for FetchTopic

source§

impl Encodable for ForgottenTopic

source§

impl Encodable for kafka_protocol::messages::fetch_request::ReplicaState

source§

impl Encodable for AbortedTransaction

source§

impl Encodable for kafka_protocol::messages::fetch_response::EpochEndOffset

source§

impl Encodable for FetchResponse

source§

impl Encodable for FetchableTopicResponse

source§

impl Encodable for kafka_protocol::messages::fetch_response::LeaderIdAndEpoch

source§

impl Encodable for kafka_protocol::messages::fetch_response::PartitionData

source§

impl Encodable for kafka_protocol::messages::fetch_response::SnapshotId

source§

impl Encodable for FetchSnapshotRequest

source§

impl Encodable for kafka_protocol::messages::fetch_snapshot_request::PartitionSnapshot

source§

impl Encodable for kafka_protocol::messages::fetch_snapshot_request::SnapshotId

source§

impl Encodable for kafka_protocol::messages::fetch_snapshot_request::TopicSnapshot

source§

impl Encodable for FetchSnapshotResponse

source§

impl Encodable for kafka_protocol::messages::fetch_snapshot_response::LeaderIdAndEpoch

source§

impl Encodable for kafka_protocol::messages::fetch_snapshot_response::PartitionSnapshot

source§

impl Encodable for kafka_protocol::messages::fetch_snapshot_response::SnapshotId

source§

impl Encodable for kafka_protocol::messages::fetch_snapshot_response::TopicSnapshot

source§

impl Encodable for FindCoordinatorRequest

source§

impl Encodable for Coordinator

source§

impl Encodable for FindCoordinatorResponse

source§

impl Encodable for GetTelemetrySubscriptionsRequest

source§

impl Encodable for GetTelemetrySubscriptionsResponse

source§

impl Encodable for HeartbeatRequest

source§

impl Encodable for HeartbeatResponse

source§

impl Encodable for kafka_protocol::messages::incremental_alter_configs_request::AlterConfigsResource

source§

impl Encodable for AlterableConfig

source§

impl Encodable for IncrementalAlterConfigsRequest

source§

impl Encodable for kafka_protocol::messages::incremental_alter_configs_response::AlterConfigsResourceResponse

source§

impl Encodable for IncrementalAlterConfigsResponse

source§

impl Encodable for InitProducerIdRequest

source§

impl Encodable for InitProducerIdResponse

source§

impl Encodable for JoinGroupRequest

source§

impl Encodable for JoinGroupResponse

source§

impl Encodable for JoinGroupResponseMember

source§

impl Encodable for LeaderAndIsrLiveLeader

source§

impl Encodable for LeaderAndIsrPartitionState

source§

impl Encodable for LeaderAndIsrRequest

source§

impl Encodable for LeaderAndIsrTopicState

source§

impl Encodable for LeaderAndIsrPartitionError

source§

impl Encodable for LeaderAndIsrResponse

source§

impl Encodable for LeaderChangeMessage

source§

impl Encodable for Voter

source§

impl Encodable for LeaveGroupRequest

source§

impl Encodable for MemberIdentity

source§

impl Encodable for LeaveGroupResponse

source§

impl Encodable for MemberResponse

source§

impl Encodable for ListClientMetricsResourcesRequest

source§

impl Encodable for ClientMetricsResource

source§

impl Encodable for ListClientMetricsResourcesResponse

source§

impl Encodable for ListGroupsRequest

source§

impl Encodable for ListGroupsResponse

source§

impl Encodable for ListedGroup

source§

impl Encodable for ListOffsetsPartition

source§

impl Encodable for ListOffsetsRequest

source§

impl Encodable for ListOffsetsTopic

source§

impl Encodable for ListOffsetsPartitionResponse

source§

impl Encodable for ListOffsetsResponse

source§

impl Encodable for ListOffsetsTopicResponse

source§

impl Encodable for ListPartitionReassignmentsRequest

source§

impl Encodable for ListPartitionReassignmentsTopics

source§

impl Encodable for ListPartitionReassignmentsResponse

source§

impl Encodable for OngoingPartitionReassignment

source§

impl Encodable for OngoingTopicReassignment

source§

impl Encodable for ListTransactionsRequest

source§

impl Encodable for ListTransactionsResponse

source§

impl Encodable for kafka_protocol::messages::list_transactions_response::TransactionState

source§

impl Encodable for MetadataRequest

source§

impl Encodable for MetadataRequestTopic

source§

impl Encodable for MetadataResponse

source§

impl Encodable for MetadataResponsePartition

source§

impl Encodable for OffsetCommitRequest

source§

impl Encodable for OffsetCommitRequestPartition

source§

impl Encodable for OffsetCommitRequestTopic

source§

impl Encodable for OffsetCommitResponse

source§

impl Encodable for OffsetCommitResponsePartition

source§

impl Encodable for OffsetCommitResponseTopic

source§

impl Encodable for OffsetDeleteRequest

source§

impl Encodable for OffsetDeleteRequestPartition

source§

impl Encodable for OffsetDeleteResponse

source§

impl Encodable for OffsetFetchRequest

source§

impl Encodable for OffsetFetchRequestGroup

source§

impl Encodable for OffsetFetchRequestTopic

source§

impl Encodable for OffsetFetchRequestTopics

source§

impl Encodable for OffsetFetchResponse

source§

impl Encodable for OffsetFetchResponseGroup

source§

impl Encodable for OffsetFetchResponsePartition

source§

impl Encodable for OffsetFetchResponsePartitions

source§

impl Encodable for OffsetFetchResponseTopic

source§

impl Encodable for OffsetFetchResponseTopics

source§

impl Encodable for OffsetForLeaderEpochRequest

source§

impl Encodable for OffsetForLeaderPartition

source§

impl Encodable for kafka_protocol::messages::offset_for_leader_epoch_response::EpochEndOffset

source§

impl Encodable for OffsetForLeaderEpochResponse

source§

impl Encodable for PartitionProduceData

source§

impl Encodable for ProduceRequest

source§

impl Encodable for BatchIndexAndErrorMessage

source§

impl Encodable for kafka_protocol::messages::produce_response::LeaderIdAndEpoch

source§

impl Encodable for PartitionProduceResponse

source§

impl Encodable for ProduceResponse

source§

impl Encodable for PushTelemetryRequest

source§

impl Encodable for PushTelemetryResponse

source§

impl Encodable for RenewDelegationTokenRequest

source§

impl Encodable for RenewDelegationTokenResponse

source§

impl Encodable for RequestHeader

source§

impl Encodable for ResponseHeader

source§

impl Encodable for SaslAuthenticateRequest

source§

impl Encodable for SaslAuthenticateResponse

source§

impl Encodable for SaslHandshakeRequest

source§

impl Encodable for SaslHandshakeResponse

source§

impl Encodable for SnapshotFooterRecord

source§

impl Encodable for SnapshotHeaderRecord

source§

impl Encodable for StopReplicaPartitionState

source§

impl Encodable for StopReplicaPartitionV0

source§

impl Encodable for StopReplicaRequest

source§

impl Encodable for StopReplicaTopicState

source§

impl Encodable for StopReplicaTopicV1

source§

impl Encodable for StopReplicaPartitionError

source§

impl Encodable for StopReplicaResponse

source§

impl Encodable for SyncGroupRequest

source§

impl Encodable for SyncGroupRequestAssignment

source§

impl Encodable for SyncGroupResponse

source§

impl Encodable for TxnOffsetCommitRequest

source§

impl Encodable for TxnOffsetCommitRequestPartition

source§

impl Encodable for TxnOffsetCommitRequestTopic

source§

impl Encodable for TxnOffsetCommitResponse

source§

impl Encodable for TxnOffsetCommitResponsePartition

source§

impl Encodable for TxnOffsetCommitResponseTopic

source§

impl Encodable for UnregisterBrokerRequest

source§

impl Encodable for UnregisterBrokerResponse

source§

impl Encodable for UpdateFeaturesRequest

source§

impl Encodable for UpdateFeaturesResponse

source§

impl Encodable for UpdateMetadataBroker

source§

impl Encodable for UpdateMetadataEndpoint

source§

impl Encodable for UpdateMetadataPartitionState

source§

impl Encodable for UpdateMetadataRequest

source§

impl Encodable for UpdateMetadataTopicState

source§

impl Encodable for UpdateMetadataResponse

source§

impl Encodable for kafka_protocol::messages::vote_request::PartitionData

source§

impl Encodable for kafka_protocol::messages::vote_request::TopicData

source§

impl Encodable for VoteRequest

source§

impl Encodable for kafka_protocol::messages::vote_response::PartitionData

source§

impl Encodable for kafka_protocol::messages::vote_response::TopicData

source§

impl Encodable for VoteResponse

source§

impl Encodable for WritableTxnMarker

source§

impl Encodable for WritableTxnMarkerTopic

source§

impl Encodable for WriteTxnMarkersRequest

source§

impl Encodable for WritableTxnMarkerPartitionResult

source§

impl Encodable for WritableTxnMarkerResult

source§

impl Encodable for WritableTxnMarkerTopicResult

source§

impl Encodable for WriteTxnMarkersResponse