Module kafka_protocol::messages

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_footer_record::SnapshotFooterRecord;

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

add_offsets_to_txn_request

AddOffsetsToTxnRequest

add_offsets_to_txn_response

AddOffsetsToTxnResponse

add_partitions_to_txn_request

AddPartitionsToTxnRequest

add_partitions_to_txn_response

AddPartitionsToTxnResponse

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

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_protocol_assignment

ConsumerProtocolAssignment

consumer_protocol_subscription

ConsumerProtocolSubscription

controlled_shutdown_request

ControlledShutdownRequest

controlled_shutdown_response

ControlledShutdownResponse

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_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

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

leader_and_isr_request

LeaderAndIsrRequest

leader_and_isr_response

LeaderAndIsrResponse

leader_change_message

LeaderChangeMessage

leave_group_request

LeaveGroupRequest

leave_group_response

LeaveGroupResponse

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

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

vote_request

VoteRequest

vote_response

VoteResponse

write_txn_markers_request

WriteTxnMarkersRequest

write_txn_markers_response

WriteTxnMarkersResponse

Structs

BrokerId

The ID of the requesting broker

GroupId

The unique group identifier.

ProducerId

Current producer id in use by the transactional id.

TopicName

The name of the topic.

TransactionalId

The transactional id corresponding to the transaction.

Enums

ApiKey

Valid API keys in the Kafka protocol.

RequestKind

Wrapping enum for all requests in the Kafka protocol.

ResponseKind

Wrapping enum for all responses in the Kafka protocol.