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 consumer_protocol_assignment::ConsumerProtocolAssignment;pub use consumer_protocol_subscription::ConsumerProtocolSubscription;pub use default_principal_data::DefaultPrincipalData;pub use leader_change_message::LeaderChangeMessage;pub use request_header::RequestHeader;pub use response_header::ResponseHeader;pub use snapshot_header_record::SnapshotHeaderRecord;pub use produce_request::ProduceRequest;pub use fetch_request::FetchRequest;pub use list_offsets_request::ListOffsetsRequest;pub use metadata_request::MetadataRequest;pub use leader_and_isr_request::LeaderAndIsrRequest;pub use stop_replica_request::StopReplicaRequest;pub use update_metadata_request::UpdateMetadataRequest;pub use controlled_shutdown_request::ControlledShutdownRequest;pub use offset_commit_request::OffsetCommitRequest;pub use offset_fetch_request::OffsetFetchRequest;pub use find_coordinator_request::FindCoordinatorRequest;pub use join_group_request::JoinGroupRequest;pub use heartbeat_request::HeartbeatRequest;pub use leave_group_request::LeaveGroupRequest;pub use sync_group_request::SyncGroupRequest;pub use describe_groups_request::DescribeGroupsRequest;pub use list_groups_request::ListGroupsRequest;pub use sasl_handshake_request::SaslHandshakeRequest;pub use api_versions_request::ApiVersionsRequest;pub use create_topics_request::CreateTopicsRequest;pub use delete_topics_request::DeleteTopicsRequest;pub use delete_records_request::DeleteRecordsRequest;pub use init_producer_id_request::InitProducerIdRequest;pub use offset_for_leader_epoch_request::OffsetForLeaderEpochRequest;pub use add_partitions_to_txn_request::AddPartitionsToTxnRequest;pub use add_offsets_to_txn_request::AddOffsetsToTxnRequest;pub use end_txn_request::EndTxnRequest;pub use write_txn_markers_request::WriteTxnMarkersRequest;pub use txn_offset_commit_request::TxnOffsetCommitRequest;pub use describe_acls_request::DescribeAclsRequest;pub use create_acls_request::CreateAclsRequest;pub use delete_acls_request::DeleteAclsRequest;pub use describe_configs_request::DescribeConfigsRequest;pub use alter_configs_request::AlterConfigsRequest;pub use alter_replica_log_dirs_request::AlterReplicaLogDirsRequest;pub use describe_log_dirs_request::DescribeLogDirsRequest;pub use sasl_authenticate_request::SaslAuthenticateRequest;pub use create_partitions_request::CreatePartitionsRequest;pub use create_delegation_token_request::CreateDelegationTokenRequest;pub use renew_delegation_token_request::RenewDelegationTokenRequest;pub use expire_delegation_token_request::ExpireDelegationTokenRequest;pub use describe_delegation_token_request::DescribeDelegationTokenRequest;pub use delete_groups_request::DeleteGroupsRequest;pub use elect_leaders_request::ElectLeadersRequest;pub use incremental_alter_configs_request::IncrementalAlterConfigsRequest;pub use alter_partition_reassignments_request::AlterPartitionReassignmentsRequest;pub use list_partition_reassignments_request::ListPartitionReassignmentsRequest;pub use offset_delete_request::OffsetDeleteRequest;pub use describe_client_quotas_request::DescribeClientQuotasRequest;pub use alter_client_quotas_request::AlterClientQuotasRequest;pub use describe_user_scram_credentials_request::DescribeUserScramCredentialsRequest;pub use alter_user_scram_credentials_request::AlterUserScramCredentialsRequest;pub use vote_request::VoteRequest;pub use begin_quorum_epoch_request::BeginQuorumEpochRequest;pub use end_quorum_epoch_request::EndQuorumEpochRequest;pub use describe_quorum_request::DescribeQuorumRequest;pub use alter_partition_request::AlterPartitionRequest;pub use update_features_request::UpdateFeaturesRequest;pub use envelope_request::EnvelopeRequest;pub use fetch_snapshot_request::FetchSnapshotRequest;pub use describe_cluster_request::DescribeClusterRequest;pub use describe_producers_request::DescribeProducersRequest;pub use broker_registration_request::BrokerRegistrationRequest;pub use broker_heartbeat_request::BrokerHeartbeatRequest;pub use unregister_broker_request::UnregisterBrokerRequest;pub use describe_transactions_request::DescribeTransactionsRequest;pub use list_transactions_request::ListTransactionsRequest;pub use allocate_producer_ids_request::AllocateProducerIdsRequest;pub use consumer_group_heartbeat_request::ConsumerGroupHeartbeatRequest;pub use controller_registration_request::ControllerRegistrationRequest;pub use get_telemetry_subscriptions_request::GetTelemetrySubscriptionsRequest;pub use push_telemetry_request::PushTelemetryRequest;pub use assign_replicas_to_dirs_request::AssignReplicasToDirsRequest;pub use list_client_metrics_resources_request::ListClientMetricsResourcesRequest;pub use produce_response::ProduceResponse;pub use fetch_response::FetchResponse;pub use list_offsets_response::ListOffsetsResponse;pub use metadata_response::MetadataResponse;pub use leader_and_isr_response::LeaderAndIsrResponse;pub use stop_replica_response::StopReplicaResponse;pub use update_metadata_response::UpdateMetadataResponse;pub use controlled_shutdown_response::ControlledShutdownResponse;pub use offset_commit_response::OffsetCommitResponse;pub use offset_fetch_response::OffsetFetchResponse;pub use find_coordinator_response::FindCoordinatorResponse;pub use join_group_response::JoinGroupResponse;pub use heartbeat_response::HeartbeatResponse;pub use leave_group_response::LeaveGroupResponse;pub use sync_group_response::SyncGroupResponse;pub use describe_groups_response::DescribeGroupsResponse;pub use list_groups_response::ListGroupsResponse;pub use sasl_handshake_response::SaslHandshakeResponse;pub use api_versions_response::ApiVersionsResponse;pub use create_topics_response::CreateTopicsResponse;pub use delete_topics_response::DeleteTopicsResponse;pub use delete_records_response::DeleteRecordsResponse;pub use init_producer_id_response::InitProducerIdResponse;pub use offset_for_leader_epoch_response::OffsetForLeaderEpochResponse;pub use add_partitions_to_txn_response::AddPartitionsToTxnResponse;pub use add_offsets_to_txn_response::AddOffsetsToTxnResponse;pub use end_txn_response::EndTxnResponse;pub use write_txn_markers_response::WriteTxnMarkersResponse;pub use txn_offset_commit_response::TxnOffsetCommitResponse;pub use describe_acls_response::DescribeAclsResponse;pub use create_acls_response::CreateAclsResponse;pub use delete_acls_response::DeleteAclsResponse;pub use describe_configs_response::DescribeConfigsResponse;pub use alter_configs_response::AlterConfigsResponse;pub use alter_replica_log_dirs_response::AlterReplicaLogDirsResponse;pub use describe_log_dirs_response::DescribeLogDirsResponse;pub use sasl_authenticate_response::SaslAuthenticateResponse;pub use create_partitions_response::CreatePartitionsResponse;pub use create_delegation_token_response::CreateDelegationTokenResponse;pub use renew_delegation_token_response::RenewDelegationTokenResponse;pub use expire_delegation_token_response::ExpireDelegationTokenResponse;pub use describe_delegation_token_response::DescribeDelegationTokenResponse;pub use delete_groups_response::DeleteGroupsResponse;pub use elect_leaders_response::ElectLeadersResponse;pub use incremental_alter_configs_response::IncrementalAlterConfigsResponse;pub use alter_partition_reassignments_response::AlterPartitionReassignmentsResponse;pub use list_partition_reassignments_response::ListPartitionReassignmentsResponse;pub use offset_delete_response::OffsetDeleteResponse;pub use describe_client_quotas_response::DescribeClientQuotasResponse;pub use alter_client_quotas_response::AlterClientQuotasResponse;pub use describe_user_scram_credentials_response::DescribeUserScramCredentialsResponse;pub use alter_user_scram_credentials_response::AlterUserScramCredentialsResponse;pub use vote_response::VoteResponse;pub use begin_quorum_epoch_response::BeginQuorumEpochResponse;pub use end_quorum_epoch_response::EndQuorumEpochResponse;pub use describe_quorum_response::DescribeQuorumResponse;pub use alter_partition_response::AlterPartitionResponse;pub use update_features_response::UpdateFeaturesResponse;pub use envelope_response::EnvelopeResponse;pub use fetch_snapshot_response::FetchSnapshotResponse;pub use describe_cluster_response::DescribeClusterResponse;pub use describe_producers_response::DescribeProducersResponse;pub use broker_registration_response::BrokerRegistrationResponse;pub use broker_heartbeat_response::BrokerHeartbeatResponse;pub use unregister_broker_response::UnregisterBrokerResponse;pub use describe_transactions_response::DescribeTransactionsResponse;pub use list_transactions_response::ListTransactionsResponse;pub use allocate_producer_ids_response::AllocateProducerIdsResponse;pub use consumer_group_heartbeat_response::ConsumerGroupHeartbeatResponse;pub use controller_registration_response::ControllerRegistrationResponse;pub use get_telemetry_subscriptions_response::GetTelemetrySubscriptionsResponse;pub use push_telemetry_response::PushTelemetryResponse;pub use assign_replicas_to_dirs_response::AssignReplicasToDirsResponse;pub use list_client_metrics_resources_response::ListClientMetricsResourcesResponse;
Modules§
- AddOffsetsToTxnRequest
- AddOffsetsToTxnResponse
- AddPartitionsToTxnRequest
- AddPartitionsToTxnResponse
- AllocateProducerIdsRequest
- AllocateProducerIdsResponse
- AlterClientQuotasRequest
- AlterClientQuotasResponse
- AlterConfigsRequest
- AlterConfigsResponse
- AlterPartitionReassignmentsRequest
- AlterPartitionReassignmentsResponse
- AlterPartitionRequest
- AlterPartitionResponse
- AlterReplicaLogDirsRequest
- AlterReplicaLogDirsResponse
- AlterUserScramCredentialsRequest
- AlterUserScramCredentialsResponse
- ApiVersionsRequest
- ApiVersionsResponse
- AssignReplicasToDirsRequest
- AssignReplicasToDirsResponse
- BeginQuorumEpochRequest
- BeginQuorumEpochResponse
- BrokerHeartbeatRequest
- BrokerHeartbeatResponse
- BrokerRegistrationRequest
- BrokerRegistrationResponse
- ConsumerGroupHeartbeatRequest
- ConsumerGroupHeartbeatResponse
- ConsumerProtocolAssignment
- ConsumerProtocolSubscription
- ControlledShutdownRequest
- ControlledShutdownResponse
- ControllerRegistrationRequest
- ControllerRegistrationResponse
- 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
- GetTelemetrySubscriptionsRequest
- GetTelemetrySubscriptionsResponse
- HeartbeatRequest
- HeartbeatResponse
- IncrementalAlterConfigsRequest
- IncrementalAlterConfigsResponse
- InitProducerIdRequest
- InitProducerIdResponse
- JoinGroupRequest
- JoinGroupResponse
- LeaderAndIsrRequest
- LeaderAndIsrResponse
- LeaderChangeMessage
- LeaveGroupRequest
- LeaveGroupResponse
- ListClientMetricsResourcesRequest
- ListClientMetricsResourcesResponse
- ListGroupsRequest
- ListGroupsResponse
- ListOffsetsRequest
- ListOffsetsResponse
- ListPartitionReassignmentsRequest
- ListPartitionReassignmentsResponse
- ListTransactionsRequest
- ListTransactionsResponse
- MetadataRequest
- MetadataResponse
- OffsetCommitRequest
- OffsetCommitResponse
- OffsetDeleteRequest
- OffsetDeleteResponse
- OffsetFetchRequest
- OffsetFetchResponse
- OffsetForLeaderEpochRequest
- OffsetForLeaderEpochResponse
- ProduceRequest
- ProduceResponse
- PushTelemetryRequest
- PushTelemetryResponse
- 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 controller broker.
- The group id
- The first producer ID in this range, inclusive
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.