Module messages

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 k_raft_version_record::KRaftVersionRecord;
pub use leader_change_message::LeaderChangeMessage;
pub use request_header::RequestHeader;
pub use response_header::ResponseHeader;
pub use snapshot_footer_record::SnapshotFooterRecord;
pub use snapshot_header_record::SnapshotHeaderRecord;
pub use voters_record::VotersRecord;
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 consumer_group_describe_request::ConsumerGroupDescribeRequest;
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 describe_topic_partitions_request::DescribeTopicPartitionsRequest;
pub use add_raft_voter_request::AddRaftVoterRequest;
pub use remove_raft_voter_request::RemoveRaftVoterRequest;
pub use update_raft_voter_request::UpdateRaftVoterRequest;
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 consumer_group_describe_response::ConsumerGroupDescribeResponse;
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;
pub use describe_topic_partitions_response::DescribeTopicPartitionsResponse;
pub use add_raft_voter_response::AddRaftVoterResponse;
pub use remove_raft_voter_response::RemoveRaftVoterResponse;
pub use update_raft_voter_response::UpdateRaftVoterResponse;

Modules§

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

Structs§

BrokerId: The replica id of the current leader or -1 if the leader is unknown
GroupId: The group ID string.
ProducerId: The first producer ID in this range, inclusive
TopicName: The topic name.
TransactionalId

Enums§

ApiKey: Valid API keys in the Kafka protocol.
RequestKindmessages_enums: Wrapping enum for all requests in the Kafka protocol.
ResponseKindmessages_enums: Wrapping enum for all responses in the Kafka protocol.

Module messagesCopy item path

Re-exports§

Modules§

Structs§

Enums§

Module messages