Module kafka_protocol::messages
source · Expand description
Messages used by the Kafka protocol.
These messages are generated programmatically. See the Kafka’s protocol documentation for more information about a given message type.
Re-exports
pub use add_offsets_to_txn_request::AddOffsetsToTxnRequest;pub use add_offsets_to_txn_response::AddOffsetsToTxnResponse;pub use add_partitions_to_txn_request::AddPartitionsToTxnRequest;pub use add_partitions_to_txn_response::AddPartitionsToTxnResponse;pub use allocate_producer_ids_request::AllocateProducerIdsRequest;pub use allocate_producer_ids_response::AllocateProducerIdsResponse;pub use alter_client_quotas_request::AlterClientQuotasRequest;pub use alter_client_quotas_response::AlterClientQuotasResponse;pub use alter_configs_request::AlterConfigsRequest;pub use alter_configs_response::AlterConfigsResponse;pub use alter_partition_reassignments_request::AlterPartitionReassignmentsRequest;pub use alter_partition_reassignments_response::AlterPartitionReassignmentsResponse;pub use alter_partition_request::AlterPartitionRequest;pub use alter_partition_response::AlterPartitionResponse;pub use alter_replica_log_dirs_request::AlterReplicaLogDirsRequest;pub use alter_replica_log_dirs_response::AlterReplicaLogDirsResponse;pub use alter_user_scram_credentials_request::AlterUserScramCredentialsRequest;pub use alter_user_scram_credentials_response::AlterUserScramCredentialsResponse;pub use api_versions_request::ApiVersionsRequest;pub use api_versions_response::ApiVersionsResponse;pub use begin_quorum_epoch_request::BeginQuorumEpochRequest;pub use begin_quorum_epoch_response::BeginQuorumEpochResponse;pub use broker_heartbeat_request::BrokerHeartbeatRequest;pub use broker_heartbeat_response::BrokerHeartbeatResponse;pub use broker_registration_request::BrokerRegistrationRequest;pub use broker_registration_response::BrokerRegistrationResponse;pub use consumer_protocol_assignment::ConsumerProtocolAssignment;pub use consumer_protocol_subscription::ConsumerProtocolSubscription;pub use controlled_shutdown_request::ControlledShutdownRequest;pub use controlled_shutdown_response::ControlledShutdownResponse;pub use create_acls_request::CreateAclsRequest;pub use create_acls_response::CreateAclsResponse;pub use create_delegation_token_request::CreateDelegationTokenRequest;pub use create_delegation_token_response::CreateDelegationTokenResponse;pub use create_partitions_request::CreatePartitionsRequest;pub use create_partitions_response::CreatePartitionsResponse;pub use create_topics_request::CreateTopicsRequest;pub use create_topics_response::CreateTopicsResponse;pub use default_principal_data::DefaultPrincipalData;pub use delete_acls_request::DeleteAclsRequest;pub use delete_acls_response::DeleteAclsResponse;pub use delete_groups_request::DeleteGroupsRequest;pub use delete_groups_response::DeleteGroupsResponse;pub use delete_records_request::DeleteRecordsRequest;pub use delete_records_response::DeleteRecordsResponse;pub use delete_topics_request::DeleteTopicsRequest;pub use delete_topics_response::DeleteTopicsResponse;pub use describe_acls_request::DescribeAclsRequest;pub use describe_acls_response::DescribeAclsResponse;pub use describe_client_quotas_request::DescribeClientQuotasRequest;pub use describe_client_quotas_response::DescribeClientQuotasResponse;pub use describe_cluster_request::DescribeClusterRequest;pub use describe_cluster_response::DescribeClusterResponse;pub use describe_configs_request::DescribeConfigsRequest;pub use describe_configs_response::DescribeConfigsResponse;pub use describe_delegation_token_request::DescribeDelegationTokenRequest;pub use describe_delegation_token_response::DescribeDelegationTokenResponse;pub use describe_groups_request::DescribeGroupsRequest;pub use describe_groups_response::DescribeGroupsResponse;pub use describe_log_dirs_request::DescribeLogDirsRequest;pub use describe_log_dirs_response::DescribeLogDirsResponse;pub use describe_producers_request::DescribeProducersRequest;pub use describe_producers_response::DescribeProducersResponse;pub use describe_quorum_request::DescribeQuorumRequest;pub use describe_quorum_response::DescribeQuorumResponse;pub use describe_transactions_request::DescribeTransactionsRequest;pub use describe_transactions_response::DescribeTransactionsResponse;pub use describe_user_scram_credentials_request::DescribeUserScramCredentialsRequest;pub use describe_user_scram_credentials_response::DescribeUserScramCredentialsResponse;pub use elect_leaders_request::ElectLeadersRequest;pub use elect_leaders_response::ElectLeadersResponse;pub use end_quorum_epoch_request::EndQuorumEpochRequest;pub use end_quorum_epoch_response::EndQuorumEpochResponse;pub use end_txn_request::EndTxnRequest;pub use end_txn_response::EndTxnResponse;pub use envelope_request::EnvelopeRequest;pub use envelope_response::EnvelopeResponse;pub use expire_delegation_token_request::ExpireDelegationTokenRequest;pub use expire_delegation_token_response::ExpireDelegationTokenResponse;pub use fetch_request::FetchRequest;pub use fetch_response::FetchResponse;pub use fetch_snapshot_request::FetchSnapshotRequest;pub use fetch_snapshot_response::FetchSnapshotResponse;pub use find_coordinator_request::FindCoordinatorRequest;pub use find_coordinator_response::FindCoordinatorResponse;pub use heartbeat_request::HeartbeatRequest;pub use heartbeat_response::HeartbeatResponse;pub use incremental_alter_configs_request::IncrementalAlterConfigsRequest;pub use incremental_alter_configs_response::IncrementalAlterConfigsResponse;pub use init_producer_id_request::InitProducerIdRequest;pub use init_producer_id_response::InitProducerIdResponse;pub use join_group_request::JoinGroupRequest;pub use join_group_response::JoinGroupResponse;pub use leader_and_isr_request::LeaderAndIsrRequest;pub use leader_and_isr_response::LeaderAndIsrResponse;pub use leader_change_message::LeaderChangeMessage;pub use leave_group_request::LeaveGroupRequest;pub use leave_group_response::LeaveGroupResponse;pub use list_groups_request::ListGroupsRequest;pub use list_groups_response::ListGroupsResponse;pub use list_offsets_request::ListOffsetsRequest;pub use list_offsets_response::ListOffsetsResponse;pub use list_partition_reassignments_request::ListPartitionReassignmentsRequest;pub use list_partition_reassignments_response::ListPartitionReassignmentsResponse;pub use list_transactions_request::ListTransactionsRequest;pub use list_transactions_response::ListTransactionsResponse;pub use metadata_request::MetadataRequest;pub use metadata_response::MetadataResponse;pub use offset_commit_request::OffsetCommitRequest;pub use offset_commit_response::OffsetCommitResponse;pub use offset_delete_request::OffsetDeleteRequest;pub use offset_delete_response::OffsetDeleteResponse;pub use offset_fetch_request::OffsetFetchRequest;pub use offset_fetch_response::OffsetFetchResponse;pub use offset_for_leader_epoch_request::OffsetForLeaderEpochRequest;pub use offset_for_leader_epoch_response::OffsetForLeaderEpochResponse;pub use produce_request::ProduceRequest;pub use produce_response::ProduceResponse;pub use renew_delegation_token_request::RenewDelegationTokenRequest;pub use renew_delegation_token_response::RenewDelegationTokenResponse;pub use request_header::RequestHeader;pub use response_header::ResponseHeader;pub use sasl_authenticate_request::SaslAuthenticateRequest;pub use sasl_authenticate_response::SaslAuthenticateResponse;pub use sasl_handshake_request::SaslHandshakeRequest;pub use sasl_handshake_response::SaslHandshakeResponse;pub use snapshot_header_record::SnapshotHeaderRecord;pub use stop_replica_request::StopReplicaRequest;pub use stop_replica_response::StopReplicaResponse;pub use sync_group_request::SyncGroupRequest;pub use sync_group_response::SyncGroupResponse;pub use txn_offset_commit_request::TxnOffsetCommitRequest;pub use txn_offset_commit_response::TxnOffsetCommitResponse;pub use unregister_broker_request::UnregisterBrokerRequest;pub use unregister_broker_response::UnregisterBrokerResponse;pub use update_features_request::UpdateFeaturesRequest;pub use update_features_response::UpdateFeaturesResponse;pub use update_metadata_request::UpdateMetadataRequest;pub use update_metadata_response::UpdateMetadataResponse;pub use vote_request::VoteRequest;pub use vote_response::VoteResponse;pub use write_txn_markers_request::WriteTxnMarkersRequest;pub use write_txn_markers_response::WriteTxnMarkersResponse;
Modules
- AddOffsetsToTxnRequest
- AddOffsetsToTxnResponse
- AddPartitionsToTxnRequest
- AddPartitionsToTxnResponse
- AllocateProducerIdsRequest
- AllocateProducerIdsResponse
- AlterClientQuotasRequest
- AlterClientQuotasResponse
- AlterConfigsRequest
- AlterConfigsResponse
- AlterPartitionReassignmentsRequest
- AlterPartitionReassignmentsResponse
- AlterPartitionRequest
- AlterPartitionResponse
- AlterReplicaLogDirsRequest
- AlterReplicaLogDirsResponse
- AlterUserScramCredentialsRequest
- AlterUserScramCredentialsResponse
- ApiVersionsRequest
- ApiVersionsResponse
- BeginQuorumEpochRequest
- BeginQuorumEpochResponse
- BrokerHeartbeatRequest
- BrokerHeartbeatResponse
- BrokerRegistrationRequest
- BrokerRegistrationResponse
- ConsumerProtocolAssignment
- ConsumerProtocolSubscription
- ControlledShutdownRequest
- ControlledShutdownResponse
- CreateAclsRequest
- CreateAclsResponse
- CreateDelegationTokenRequest
- CreateDelegationTokenResponse
- CreatePartitionsRequest
- CreatePartitionsResponse
- CreateTopicsRequest
- CreateTopicsResponse
- DefaultPrincipalData
- DeleteAclsRequest
- DeleteAclsResponse
- DeleteGroupsRequest
- DeleteGroupsResponse
- DeleteRecordsRequest
- DeleteRecordsResponse
- DeleteTopicsRequest
- DeleteTopicsResponse
- DescribeAclsRequest
- DescribeAclsResponse
- DescribeClientQuotasRequest
- DescribeClientQuotasResponse
- DescribeClusterRequest
- DescribeClusterResponse
- DescribeConfigsRequest
- DescribeConfigsResponse
- DescribeDelegationTokenRequest
- DescribeDelegationTokenResponse
- DescribeGroupsRequest
- DescribeGroupsResponse
- DescribeLogDirsRequest
- DescribeLogDirsResponse
- DescribeProducersRequest
- DescribeProducersResponse
- DescribeQuorumRequest
- DescribeQuorumResponse
- DescribeTransactionsRequest
- DescribeTransactionsResponse
- DescribeUserScramCredentialsRequest
- DescribeUserScramCredentialsResponse
- ElectLeadersRequest
- ElectLeadersResponse
- EndQuorumEpochRequest
- EndQuorumEpochResponse
- EndTxnRequest
- EndTxnResponse
- EnvelopeRequest
- EnvelopeResponse
- ExpireDelegationTokenRequest
- ExpireDelegationTokenResponse
- FetchRequest
- FetchResponse
- FetchSnapshotRequest
- FetchSnapshotResponse
- FindCoordinatorRequest
- FindCoordinatorResponse
- HeartbeatRequest
- HeartbeatResponse
- IncrementalAlterConfigsRequest
- IncrementalAlterConfigsResponse
- InitProducerIdRequest
- InitProducerIdResponse
- JoinGroupRequest
- JoinGroupResponse
- LeaderAndIsrRequest
- LeaderAndIsrResponse
- LeaderChangeMessage
- LeaveGroupRequest
- LeaveGroupResponse
- ListGroupsRequest
- ListGroupsResponse
- ListOffsetsRequest
- ListOffsetsResponse
- ListPartitionReassignmentsRequest
- ListPartitionReassignmentsResponse
- ListTransactionsRequest
- ListTransactionsResponse
- MetadataRequest
- MetadataResponse
- OffsetCommitRequest
- OffsetCommitResponse
- OffsetDeleteRequest
- OffsetDeleteResponse
- OffsetFetchRequest
- OffsetFetchResponse
- OffsetForLeaderEpochRequest
- OffsetForLeaderEpochResponse
- ProduceRequest
- ProduceResponse
- RenewDelegationTokenRequest
- RenewDelegationTokenResponse
- RequestHeader
- ResponseHeader
- SaslAuthenticateRequest
- SaslAuthenticateResponse
- SaslHandshakeRequest
- SaslHandshakeResponse
- SnapshotFooterRecord
- SnapshotHeaderRecord
- StopReplicaRequest
- StopReplicaResponse
- SyncGroupRequest
- SyncGroupResponse
- TxnOffsetCommitRequest
- TxnOffsetCommitResponse
- UnregisterBrokerRequest
- UnregisterBrokerResponse
- UpdateFeaturesRequest
- UpdateFeaturesResponse
- UpdateMetadataRequest
- UpdateMetadataResponse
- VoteRequest
- VoteResponse
- WriteTxnMarkersRequest
- WriteTxnMarkersResponse
Structs
- The ID of the requesting broker
- The unique group identifier.
- Current producer id in use by the transactional id.
- The name of the topic.
- The transactional id corresponding to the transaction.
Enums
- Valid API keys in the Kafka protocol.
- Wrapping enum for all requests in the Kafka protocol.
- Wrapping enum for all responses in the Kafka protocol.