pub trait Message: Sized {
    const VERSIONS: VersionRange;
    const DEPRECATED_VERSIONS: Option<VersionRange>;
}
Expand description

An API request or response.

All API messages must provide a set of valid versions.

Required Associated Constants§

source

const VERSIONS: VersionRange

The valid versions for this message.

source

const DEPRECATED_VERSIONS: Option<VersionRange>

The deprecated versions for this message.

Object Safety§

This trait is not object safe.

Implementors§

source§

impl Message for AddOffsetsToTxnRequest

source§

impl Message for AddOffsetsToTxnResponse

source§

impl Message for AddPartitionsToTxnRequest

source§

impl Message for AddPartitionsToTxnTopic

source§

impl Message for AddPartitionsToTxnTransaction

source§

impl Message for AddPartitionsToTxnPartitionResult

source§

impl Message for AddPartitionsToTxnResponse

source§

impl Message for AddPartitionsToTxnResult

source§

impl Message for AddPartitionsToTxnTopicResult

source§

impl Message for AllocateProducerIdsRequest

source§

impl Message for AllocateProducerIdsResponse

source§

impl Message for AlterClientQuotasRequest

source§

impl Message for kafka_protocol::messages::alter_client_quotas_request::EntityData

source§

impl Message for kafka_protocol::messages::alter_client_quotas_request::EntryData

source§

impl Message for OpData

source§

impl Message for AlterClientQuotasResponse

source§

impl Message for kafka_protocol::messages::alter_client_quotas_response::EntityData

source§

impl Message for kafka_protocol::messages::alter_client_quotas_response::EntryData

source§

impl Message for AlterConfigsRequest

source§

impl Message for kafka_protocol::messages::alter_configs_request::AlterConfigsResource

source§

impl Message for kafka_protocol::messages::alter_configs_request::AlterableConfig

source§

impl Message for kafka_protocol::messages::alter_configs_response::AlterConfigsResourceResponse

source§

impl Message for AlterConfigsResponse

source§

impl Message for AlterPartitionReassignmentsRequest

source§

impl Message for ReassignablePartition

source§

impl Message for ReassignableTopic

source§

impl Message for AlterPartitionReassignmentsResponse

source§

impl Message for ReassignablePartitionResponse

source§

impl Message for ReassignableTopicResponse

source§

impl Message for AlterPartitionRequest

source§

impl Message for BrokerState

source§

impl Message for kafka_protocol::messages::alter_partition_request::PartitionData

source§

impl Message for kafka_protocol::messages::alter_partition_request::TopicData

source§

impl Message for AlterPartitionResponse

source§

impl Message for kafka_protocol::messages::alter_partition_response::PartitionData

source§

impl Message for kafka_protocol::messages::alter_partition_response::TopicData

source§

impl Message for AlterReplicaLogDir

source§

impl Message for AlterReplicaLogDirTopic

source§

impl Message for AlterReplicaLogDirsRequest

source§

impl Message for AlterReplicaLogDirPartitionResult

source§

impl Message for AlterReplicaLogDirTopicResult

source§

impl Message for AlterReplicaLogDirsResponse

source§

impl Message for AlterUserScramCredentialsRequest

source§

impl Message for ScramCredentialDeletion

source§

impl Message for ScramCredentialUpsertion

source§

impl Message for AlterUserScramCredentialsResponse

source§

impl Message for AlterUserScramCredentialsResult

source§

impl Message for ApiVersionsRequest

source§

impl Message for ApiVersion

source§

impl Message for ApiVersionsResponse

source§

impl Message for FinalizedFeatureKey

source§

impl Message for SupportedFeatureKey

source§

impl Message for AssignReplicasToDirsRequest

source§

impl Message for kafka_protocol::messages::assign_replicas_to_dirs_request::DirectoryData

source§

impl Message for kafka_protocol::messages::assign_replicas_to_dirs_request::PartitionData

source§

impl Message for kafka_protocol::messages::assign_replicas_to_dirs_request::TopicData

source§

impl Message for AssignReplicasToDirsResponse

source§

impl Message for kafka_protocol::messages::assign_replicas_to_dirs_response::DirectoryData

source§

impl Message for kafka_protocol::messages::assign_replicas_to_dirs_response::PartitionData

source§

impl Message for kafka_protocol::messages::assign_replicas_to_dirs_response::TopicData

source§

impl Message for BeginQuorumEpochRequest

source§

impl Message for kafka_protocol::messages::begin_quorum_epoch_request::PartitionData

source§

impl Message for kafka_protocol::messages::begin_quorum_epoch_request::TopicData

source§

impl Message for BeginQuorumEpochResponse

source§

impl Message for kafka_protocol::messages::begin_quorum_epoch_response::PartitionData

source§

impl Message for kafka_protocol::messages::begin_quorum_epoch_response::TopicData

source§

impl Message for BrokerHeartbeatRequest

source§

impl Message for BrokerHeartbeatResponse

source§

impl Message for BrokerRegistrationRequest

source§

impl Message for kafka_protocol::messages::broker_registration_request::Feature

source§

impl Message for kafka_protocol::messages::broker_registration_request::Listener

source§

impl Message for BrokerRegistrationResponse

source§

impl Message for ConsumerGroupHeartbeatRequest

source§

impl Message for kafka_protocol::messages::consumer_group_heartbeat_request::TopicPartitions

source§

impl Message for Assignment

source§

impl Message for ConsumerGroupHeartbeatResponse

source§

impl Message for kafka_protocol::messages::consumer_group_heartbeat_response::TopicPartitions

source§

impl Message for ConsumerProtocolAssignment

source§

impl Message for kafka_protocol::messages::consumer_protocol_assignment::TopicPartition

source§

impl Message for ConsumerProtocolSubscription

source§

impl Message for kafka_protocol::messages::consumer_protocol_subscription::TopicPartition

source§

impl Message for ControlledShutdownRequest

source§

impl Message for ControlledShutdownResponse

source§

impl Message for RemainingPartition

source§

impl Message for ControllerRegistrationRequest

source§

impl Message for kafka_protocol::messages::controller_registration_request::Feature

source§

impl Message for kafka_protocol::messages::controller_registration_request::Listener

source§

impl Message for ControllerRegistrationResponse

source§

impl Message for AclCreation

source§

impl Message for CreateAclsRequest

source§

impl Message for AclCreationResult

source§

impl Message for CreateAclsResponse

source§

impl Message for CreatableRenewers

source§

impl Message for CreateDelegationTokenRequest

source§

impl Message for CreateDelegationTokenResponse

source§

impl Message for CreatePartitionsAssignment

source§

impl Message for CreatePartitionsRequest

source§

impl Message for CreatePartitionsTopic

source§

impl Message for CreatePartitionsResponse

source§

impl Message for CreatePartitionsTopicResult

source§

impl Message for CreatableReplicaAssignment

source§

impl Message for CreatableTopic

source§

impl Message for CreateTopicsRequest

source§

impl Message for CreateableTopicConfig

source§

impl Message for CreatableTopicConfigs

source§

impl Message for CreatableTopicResult

source§

impl Message for CreateTopicsResponse

source§

impl Message for DefaultPrincipalData

source§

impl Message for DeleteAclsFilter

source§

impl Message for DeleteAclsRequest

source§

impl Message for DeleteAclsFilterResult

source§

impl Message for DeleteAclsMatchingAcl

source§

impl Message for DeleteAclsResponse

source§

impl Message for DeleteGroupsRequest

source§

impl Message for DeletableGroupResult

source§

impl Message for DeleteGroupsResponse

source§

impl Message for DeleteRecordsPartition

source§

impl Message for DeleteRecordsRequest

source§

impl Message for DeleteRecordsTopic

source§

impl Message for DeleteRecordsPartitionResult

source§

impl Message for DeleteRecordsResponse

source§

impl Message for DeleteRecordsTopicResult

source§

impl Message for DeleteTopicState

source§

impl Message for DeleteTopicsRequest

source§

impl Message for DeletableTopicResult

source§

impl Message for DeleteTopicsResponse

source§

impl Message for DescribeAclsRequest

source§

impl Message for AclDescription

source§

impl Message for DescribeAclsResource

source§

impl Message for DescribeAclsResponse

source§

impl Message for ComponentData

source§

impl Message for DescribeClientQuotasRequest

source§

impl Message for DescribeClientQuotasResponse

source§

impl Message for kafka_protocol::messages::describe_client_quotas_response::EntityData

source§

impl Message for kafka_protocol::messages::describe_client_quotas_response::EntryData

source§

impl Message for ValueData

source§

impl Message for DescribeClusterRequest

source§

impl Message for DescribeClusterBroker

source§

impl Message for DescribeClusterResponse

source§

impl Message for DescribeConfigsRequest

source§

impl Message for DescribeConfigsResource

source§

impl Message for DescribeConfigsResourceResult

source§

impl Message for DescribeConfigsResponse

source§

impl Message for DescribeConfigsResult

source§

impl Message for DescribeConfigsSynonym

source§

impl Message for DescribeDelegationTokenOwner

source§

impl Message for DescribeDelegationTokenRequest

source§

impl Message for DescribeDelegationTokenResponse

source§

impl Message for DescribedDelegationToken

source§

impl Message for DescribedDelegationTokenRenewer

source§

impl Message for DescribeGroupsRequest

source§

impl Message for DescribeGroupsResponse

source§

impl Message for DescribedGroup

source§

impl Message for DescribedGroupMember

source§

impl Message for DescribableLogDirTopic

source§

impl Message for DescribeLogDirsRequest

source§

impl Message for DescribeLogDirsPartition

source§

impl Message for DescribeLogDirsResponse

source§

impl Message for DescribeLogDirsResult

source§

impl Message for DescribeLogDirsTopic

source§

impl Message for DescribeProducersRequest

source§

impl Message for TopicRequest

source§

impl Message for DescribeProducersResponse

source§

impl Message for PartitionResponse

source§

impl Message for ProducerState

source§

impl Message for TopicResponse

source§

impl Message for DescribeQuorumRequest

source§

impl Message for kafka_protocol::messages::describe_quorum_request::PartitionData

source§

impl Message for kafka_protocol::messages::describe_quorum_request::TopicData

source§

impl Message for DescribeQuorumResponse

source§

impl Message for kafka_protocol::messages::describe_quorum_response::PartitionData

source§

impl Message for kafka_protocol::messages::describe_quorum_response::ReplicaState

source§

impl Message for kafka_protocol::messages::describe_quorum_response::TopicData

source§

impl Message for DescribeTransactionsRequest

source§

impl Message for DescribeTransactionsResponse

source§

impl Message for kafka_protocol::messages::describe_transactions_response::TopicData

source§

impl Message for kafka_protocol::messages::describe_transactions_response::TransactionState

source§

impl Message for DescribeUserScramCredentialsRequest

source§

impl Message for UserName

source§

impl Message for CredentialInfo

source§

impl Message for DescribeUserScramCredentialsResponse

source§

impl Message for DescribeUserScramCredentialsResult

source§

impl Message for ElectLeadersRequest

source§

impl Message for kafka_protocol::messages::elect_leaders_request::TopicPartitions

source§

impl Message for ElectLeadersResponse

source§

impl Message for PartitionResult

source§

impl Message for ReplicaElectionResult

source§

impl Message for EndQuorumEpochRequest

source§

impl Message for kafka_protocol::messages::end_quorum_epoch_request::PartitionData

source§

impl Message for kafka_protocol::messages::end_quorum_epoch_request::TopicData

source§

impl Message for EndQuorumEpochResponse

source§

impl Message for kafka_protocol::messages::end_quorum_epoch_response::PartitionData

source§

impl Message for kafka_protocol::messages::end_quorum_epoch_response::TopicData

source§

impl Message for EndTxnRequest

source§

impl Message for EndTxnResponse

source§

impl Message for EnvelopeRequest

source§

impl Message for EnvelopeResponse

source§

impl Message for ExpireDelegationTokenRequest

source§

impl Message for ExpireDelegationTokenResponse

source§

impl Message for FetchPartition

source§

impl Message for FetchRequest

source§

impl Message for FetchTopic

source§

impl Message for ForgottenTopic

source§

impl Message for kafka_protocol::messages::fetch_request::ReplicaState

source§

impl Message for AbortedTransaction

source§

impl Message for kafka_protocol::messages::fetch_response::EpochEndOffset

source§

impl Message for FetchResponse

source§

impl Message for FetchableTopicResponse

source§

impl Message for kafka_protocol::messages::fetch_response::LeaderIdAndEpoch

source§

impl Message for kafka_protocol::messages::fetch_response::NodeEndpoint

source§

impl Message for kafka_protocol::messages::fetch_response::PartitionData

source§

impl Message for kafka_protocol::messages::fetch_response::SnapshotId

source§

impl Message for FetchSnapshotRequest

source§

impl Message for kafka_protocol::messages::fetch_snapshot_request::PartitionSnapshot

source§

impl Message for kafka_protocol::messages::fetch_snapshot_request::SnapshotId

source§

impl Message for kafka_protocol::messages::fetch_snapshot_request::TopicSnapshot

source§

impl Message for FetchSnapshotResponse

source§

impl Message for kafka_protocol::messages::fetch_snapshot_response::LeaderIdAndEpoch

source§

impl Message for kafka_protocol::messages::fetch_snapshot_response::PartitionSnapshot

source§

impl Message for kafka_protocol::messages::fetch_snapshot_response::SnapshotId

source§

impl Message for kafka_protocol::messages::fetch_snapshot_response::TopicSnapshot

source§

impl Message for FindCoordinatorRequest

source§

impl Message for Coordinator

source§

impl Message for FindCoordinatorResponse

source§

impl Message for GetTelemetrySubscriptionsRequest

source§

impl Message for GetTelemetrySubscriptionsResponse

source§

impl Message for HeartbeatRequest

source§

impl Message for HeartbeatResponse

source§

impl Message for kafka_protocol::messages::incremental_alter_configs_request::AlterConfigsResource

source§

impl Message for kafka_protocol::messages::incremental_alter_configs_request::AlterableConfig

source§

impl Message for IncrementalAlterConfigsRequest

source§

impl Message for kafka_protocol::messages::incremental_alter_configs_response::AlterConfigsResourceResponse

source§

impl Message for IncrementalAlterConfigsResponse

source§

impl Message for InitProducerIdRequest

source§

impl Message for InitProducerIdResponse

source§

impl Message for JoinGroupRequest

source§

impl Message for JoinGroupRequestProtocol

source§

impl Message for JoinGroupResponse

source§

impl Message for JoinGroupResponseMember

source§

impl Message for LeaderAndIsrLiveLeader

source§

impl Message for LeaderAndIsrPartitionState

source§

impl Message for LeaderAndIsrRequest

source§

impl Message for LeaderAndIsrTopicState

source§

impl Message for LeaderAndIsrPartitionError

source§

impl Message for LeaderAndIsrResponse

source§

impl Message for LeaderAndIsrTopicError

source§

impl Message for LeaderChangeMessage

source§

impl Message for Voter

source§

impl Message for LeaveGroupRequest

source§

impl Message for MemberIdentity

source§

impl Message for LeaveGroupResponse

source§

impl Message for MemberResponse

source§

impl Message for ListClientMetricsResourcesRequest

source§

impl Message for ClientMetricsResource

source§

impl Message for ListClientMetricsResourcesResponse

source§

impl Message for ListGroupsRequest

source§

impl Message for ListGroupsResponse

source§

impl Message for ListedGroup

source§

impl Message for ListOffsetsPartition

source§

impl Message for ListOffsetsRequest

source§

impl Message for ListOffsetsTopic

source§

impl Message for ListOffsetsPartitionResponse

source§

impl Message for ListOffsetsResponse

source§

impl Message for ListOffsetsTopicResponse

source§

impl Message for ListPartitionReassignmentsRequest

source§

impl Message for ListPartitionReassignmentsTopics

source§

impl Message for ListPartitionReassignmentsResponse

source§

impl Message for OngoingPartitionReassignment

source§

impl Message for OngoingTopicReassignment

source§

impl Message for ListTransactionsRequest

source§

impl Message for ListTransactionsResponse

source§

impl Message for kafka_protocol::messages::list_transactions_response::TransactionState

source§

impl Message for MetadataRequest

source§

impl Message for MetadataRequestTopic

source§

impl Message for MetadataResponse

source§

impl Message for MetadataResponseBroker

source§

impl Message for MetadataResponsePartition

source§

impl Message for MetadataResponseTopic

source§

impl Message for OffsetCommitRequest

source§

impl Message for OffsetCommitRequestPartition

source§

impl Message for OffsetCommitRequestTopic

source§

impl Message for OffsetCommitResponse

source§

impl Message for OffsetCommitResponsePartition

source§

impl Message for OffsetCommitResponseTopic

source§

impl Message for OffsetDeleteRequest

source§

impl Message for OffsetDeleteRequestPartition

source§

impl Message for OffsetDeleteRequestTopic

source§

impl Message for OffsetDeleteResponse

source§

impl Message for OffsetDeleteResponsePartition

source§

impl Message for OffsetDeleteResponseTopic

source§

impl Message for OffsetFetchRequest

source§

impl Message for OffsetFetchRequestGroup

source§

impl Message for OffsetFetchRequestTopic

source§

impl Message for OffsetFetchRequestTopics

source§

impl Message for OffsetFetchResponse

source§

impl Message for OffsetFetchResponseGroup

source§

impl Message for OffsetFetchResponsePartition

source§

impl Message for OffsetFetchResponsePartitions

source§

impl Message for OffsetFetchResponseTopic

source§

impl Message for OffsetFetchResponseTopics

source§

impl Message for OffsetForLeaderEpochRequest

source§

impl Message for OffsetForLeaderPartition

source§

impl Message for OffsetForLeaderTopic

source§

impl Message for kafka_protocol::messages::offset_for_leader_epoch_response::EpochEndOffset

source§

impl Message for OffsetForLeaderEpochResponse

source§

impl Message for OffsetForLeaderTopicResult

source§

impl Message for PartitionProduceData

source§

impl Message for ProduceRequest

source§

impl Message for TopicProduceData

source§

impl Message for BatchIndexAndErrorMessage

source§

impl Message for kafka_protocol::messages::produce_response::LeaderIdAndEpoch

source§

impl Message for kafka_protocol::messages::produce_response::NodeEndpoint

source§

impl Message for PartitionProduceResponse

source§

impl Message for ProduceResponse

source§

impl Message for TopicProduceResponse

source§

impl Message for PushTelemetryRequest

source§

impl Message for PushTelemetryResponse

source§

impl Message for RenewDelegationTokenRequest

source§

impl Message for RenewDelegationTokenResponse

source§

impl Message for RequestHeader

source§

impl Message for ResponseHeader

source§

impl Message for SaslAuthenticateRequest

source§

impl Message for SaslAuthenticateResponse

source§

impl Message for SaslHandshakeRequest

source§

impl Message for SaslHandshakeResponse

source§

impl Message for SnapshotFooterRecord

source§

impl Message for SnapshotHeaderRecord

source§

impl Message for StopReplicaPartitionState

source§

impl Message for StopReplicaPartitionV0

source§

impl Message for StopReplicaRequest

source§

impl Message for StopReplicaTopicState

source§

impl Message for StopReplicaTopicV1

source§

impl Message for StopReplicaPartitionError

source§

impl Message for StopReplicaResponse

source§

impl Message for SyncGroupRequest

source§

impl Message for SyncGroupRequestAssignment

source§

impl Message for SyncGroupResponse

source§

impl Message for TxnOffsetCommitRequest

source§

impl Message for TxnOffsetCommitRequestPartition

source§

impl Message for TxnOffsetCommitRequestTopic

source§

impl Message for TxnOffsetCommitResponse

source§

impl Message for TxnOffsetCommitResponsePartition

source§

impl Message for TxnOffsetCommitResponseTopic

source§

impl Message for UnregisterBrokerRequest

source§

impl Message for UnregisterBrokerResponse

source§

impl Message for FeatureUpdateKey

source§

impl Message for UpdateFeaturesRequest

source§

impl Message for UpdatableFeatureResult

source§

impl Message for UpdateFeaturesResponse

source§

impl Message for UpdateMetadataBroker

source§

impl Message for UpdateMetadataEndpoint

source§

impl Message for UpdateMetadataPartitionState

source§

impl Message for UpdateMetadataRequest

source§

impl Message for UpdateMetadataTopicState

source§

impl Message for UpdateMetadataResponse

source§

impl Message for kafka_protocol::messages::vote_request::PartitionData

source§

impl Message for kafka_protocol::messages::vote_request::TopicData

source§

impl Message for VoteRequest

source§

impl Message for kafka_protocol::messages::vote_response::PartitionData

source§

impl Message for kafka_protocol::messages::vote_response::TopicData

source§

impl Message for VoteResponse

source§

impl Message for WritableTxnMarker

source§

impl Message for WritableTxnMarkerTopic

source§

impl Message for WriteTxnMarkersRequest

source§

impl Message for WritableTxnMarkerPartitionResult

source§

impl Message for WritableTxnMarkerResult

source§

impl Message for WritableTxnMarkerTopicResult

source§

impl Message for WriteTxnMarkersResponse