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 end_txn_marker::EndTxnMarker;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_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 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_config_resources_request::ListConfigResourcesRequest;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 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_config_resources_response::ListConfigResourcesResponse;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_
share_ group_ offsets_ request - AlterShareGroupOffsetsRequest
- alter_
share_ group_ offsets_ response - AlterShareGroupOffsetsResponse
- 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
- 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_
share_ group_ offsets_ request - DeleteShareGroupOffsetsRequest
- delete_
share_ group_ offsets_ response - DeleteShareGroupOffsetsResponse
- delete_
share_ group_ state_ request - DeleteShareGroupStateRequest
- delete_
share_ group_ state_ response - DeleteShareGroupStateResponse
- 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_
share_ group_ offsets_ request - DescribeShareGroupOffsetsRequest
- describe_
share_ group_ offsets_ response - DescribeShareGroupOffsetsResponse
- 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_ marker - EndTxnMarker
- 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
- initialize_
share_ group_ state_ request - InitializeShareGroupStateRequest
- initialize_
share_ group_ state_ response - InitializeShareGroupStateResponse
- join_
group_ request - JoinGroupRequest
- join_
group_ response - JoinGroupResponse
- k_
raft_ version_ record - KRaftVersionRecord
- leader_
change_ message - LeaderChangeMessage
- leave_
group_ request - LeaveGroupRequest
- leave_
group_ response - LeaveGroupResponse
- list_
config_ resources_ request - ListConfigResourcesRequest
- list_
config_ resources_ response - ListConfigResourcesResponse
- 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
- read_
share_ group_ state_ request - ReadShareGroupStateRequest
- read_
share_ group_ state_ response - ReadShareGroupStateResponse
- read_
share_ group_ state_ summary_ request - ReadShareGroupStateSummaryRequest
- read_
share_ group_ state_ summary_ response - ReadShareGroupStateSummaryResponse
- 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
- share_
acknowledge_ request - ShareAcknowledgeRequest
- share_
acknowledge_ response - ShareAcknowledgeResponse
- share_
fetch_ request - ShareFetchRequest
- share_
fetch_ response - ShareFetchResponse
- share_
group_ describe_ request - ShareGroupDescribeRequest
- share_
group_ describe_ response - ShareGroupDescribeResponse
- share_
group_ heartbeat_ request - ShareGroupHeartbeatRequest
- share_
group_ heartbeat_ response - ShareGroupHeartbeatResponse
- snapshot_
footer_ record - SnapshotFooterRecord
- snapshot_
header_ record - SnapshotHeaderRecord
- 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_
raft_ voter_ request - UpdateRaftVoterRequest
- update_
raft_ voter_ response - UpdateRaftVoterResponse
- vote_
request - VoteRequest
- vote_
response - VoteResponse
- voters_
record - VotersRecord
- write_
share_ group_ state_ request - WriteShareGroupStateRequest
- write_
share_ group_ state_ response - WriteShareGroupStateResponse
- write_
txn_ markers_ request - WriteTxnMarkersRequest
- write_
txn_ markers_ response - WriteTxnMarkersResponse
Structs§
- Broker
Id - The replica id of the current leader or -1 if the leader is unknown.
- GroupId
- The group identifier.
- Producer
Id - The first producer ID in this range, inclusive.
- Topic
Name - The topic name.
- Transactional
Id - The transactional id.
Enums§
- ApiKey
- Valid API keys in the Kafka protocol.
- Request
Kind messages_enums - Wrapping enum for all requests in the Kafka protocol.
- Response
Kind messages_enums - Wrapping enum for all responses in the Kafka protocol.