Module generated 

Generated Kafka protocol message types — DO NOT EDIT

Re-exports

pub use error_code::ErrorCode;

pub use add_offsets_to_txn_request::*;

pub use add_offsets_to_txn_response::*;

pub use add_partitions_to_txn_request::*;

pub use add_partitions_to_txn_response::*;

pub use add_raft_voter_request::*;

pub use add_raft_voter_response::*;

pub use allocate_producer_ids_request::*;

pub use allocate_producer_ids_response::*;

pub use alter_client_quotas_request::*;

pub use alter_client_quotas_response::*;

pub use alter_configs_request::*;

pub use alter_configs_response::*;

pub use alter_partition_reassignments_request::*;

pub use alter_partition_reassignments_response::*;

pub use alter_partition_request::*;

pub use alter_partition_response::*;

pub use alter_replica_log_dirs_request::*;

pub use alter_replica_log_dirs_response::*;

pub use alter_share_group_offsets_request::*;

pub use alter_share_group_offsets_response::*;

pub use alter_user_scram_credentials_request::*;

pub use alter_user_scram_credentials_response::*;

pub use api_versions_request::*;

pub use api_versions_response::*;

pub use assign_replicas_to_dirs_request::*;

pub use assign_replicas_to_dirs_response::*;

pub use begin_quorum_epoch_request::*;

pub use begin_quorum_epoch_response::*;

pub use broker_heartbeat_request::*;

pub use broker_heartbeat_response::*;

pub use broker_registration_request::*;

pub use broker_registration_response::*;

pub use consumer_group_describe_request::*;

pub use consumer_group_describe_response::*;

pub use consumer_group_heartbeat_request::*;

pub use consumer_group_heartbeat_response::*;

pub use consumer_protocol_assignment::*;

pub use consumer_protocol_subscription::*;

pub use control_record_type_schema::*;

pub use controlled_shutdown_request::*;

pub use controlled_shutdown_response::*;

pub use controller_registration_request::*;

pub use controller_registration_response::*;

pub use create_acls_request::*;

pub use create_acls_response::*;

pub use create_delegation_token_request::*;

pub use create_delegation_token_response::*;

pub use create_partitions_request::*;

pub use create_partitions_response::*;

pub use create_topics_request::*;

pub use create_topics_response::*;

pub use default_principal_data::*;

pub use delete_acls_request::*;

pub use delete_acls_response::*;

pub use delete_groups_request::*;

pub use delete_groups_response::*;

pub use delete_records_request::*;

pub use delete_records_response::*;

pub use delete_share_group_offsets_request::*;

pub use delete_share_group_offsets_response::*;

pub use delete_share_group_state_request::*;

pub use delete_share_group_state_response::*;

pub use delete_topics_request::*;

pub use delete_topics_response::*;

pub use describe_acls_request::*;

pub use describe_acls_response::*;

pub use describe_client_quotas_request::*;

pub use describe_client_quotas_response::*;

pub use describe_cluster_request::*;

pub use describe_cluster_response::*;

pub use describe_configs_request::*;

pub use describe_configs_response::*;

pub use describe_delegation_token_request::*;

pub use describe_delegation_token_response::*;

pub use describe_groups_request::*;

pub use describe_groups_response::*;

pub use describe_log_dirs_request::*;

pub use describe_log_dirs_response::*;

pub use describe_producers_request::*;

pub use describe_producers_response::*;

pub use describe_quorum_request::*;

pub use describe_quorum_response::*;

pub use describe_share_group_offsets_request::*;

pub use describe_share_group_offsets_response::*;

pub use describe_topic_partitions_request::*;

pub use describe_topic_partitions_response::*;

pub use describe_transactions_request::*;

pub use describe_transactions_response::*;

pub use describe_user_scram_credentials_request::*;

pub use describe_user_scram_credentials_response::*;

pub use elect_leaders_request::*;

pub use elect_leaders_response::*;

pub use end_quorum_epoch_request::*;

pub use end_quorum_epoch_response::*;

pub use end_txn_marker::*;

pub use end_txn_request::*;

pub use end_txn_response::*;

pub use envelope_request::*;

pub use envelope_response::*;

pub use expire_delegation_token_request::*;

pub use expire_delegation_token_response::*;

pub use fetch_request::*;

pub use fetch_response::*;

pub use fetch_snapshot_request::*;

pub use fetch_snapshot_response::*;

pub use find_coordinator_request::*;

pub use find_coordinator_response::*;

pub use get_telemetry_subscriptions_request::*;

pub use get_telemetry_subscriptions_response::*;

pub use heartbeat_request::*;

pub use heartbeat_response::*;

pub use incremental_alter_configs_request::*;

pub use incremental_alter_configs_response::*;

pub use init_producer_id_request::*;

pub use init_producer_id_response::*;

pub use initialize_share_group_state_request::*;

pub use initialize_share_group_state_response::*;

pub use join_group_request::*;

pub use join_group_response::*;

pub use k_raft_version_record::*;

pub use leader_and_isr_request::*;

pub use leader_and_isr_response::*;

pub use leader_change_message::*;

pub use leave_group_request::*;

pub use leave_group_response::*;

pub use list_config_resources_request::*;

pub use list_config_resources_response::*;

pub use list_groups_request::*;

pub use list_groups_response::*;

pub use list_offsets_request::*;

pub use list_offsets_response::*;

pub use list_partition_reassignments_request::*;

pub use list_partition_reassignments_response::*;

pub use list_transactions_request::*;

pub use list_transactions_response::*;

pub use metadata_request::*;

pub use metadata_response::*;

pub use offset_commit_request::*;

pub use offset_commit_response::*;

pub use offset_delete_request::*;

pub use offset_delete_response::*;

pub use offset_fetch_request::*;

pub use offset_fetch_response::*;

pub use offset_for_leader_epoch_request::*;

pub use offset_for_leader_epoch_response::*;

pub use produce_request::*;

pub use produce_response::*;

pub use push_telemetry_request::*;

pub use push_telemetry_response::*;

pub use read_share_group_state_request::*;

pub use read_share_group_state_response::*;

pub use read_share_group_state_summary_request::*;

pub use read_share_group_state_summary_response::*;

pub use remove_raft_voter_request::*;

pub use remove_raft_voter_response::*;

pub use renew_delegation_token_request::*;

pub use renew_delegation_token_response::*;

pub use request_header::*;

pub use response_header::*;

pub use sasl_authenticate_request::*;

pub use sasl_authenticate_response::*;

pub use sasl_handshake_request::*;

pub use sasl_handshake_response::*;

pub use share_acknowledge_request::*;

pub use share_acknowledge_response::*;

pub use share_fetch_request::*;

pub use share_fetch_response::*;

pub use share_group_describe_request::*;

pub use share_group_describe_response::*;

pub use share_group_heartbeat_request::*;

pub use share_group_heartbeat_response::*;

pub use snapshot_footer_record::*;

pub use snapshot_header_record::*;

pub use stop_replica_request::*;

pub use stop_replica_response::*;

pub use streams_group_describe_request::*;

pub use streams_group_describe_response::*;

pub use streams_group_heartbeat_request::*;

pub use streams_group_heartbeat_response::*;

pub use sync_group_request::*;

pub use sync_group_response::*;

pub use txn_offset_commit_request::*;

pub use txn_offset_commit_response::*;

pub use unregister_broker_request::*;

pub use unregister_broker_response::*;

pub use update_features_request::*;

pub use update_features_response::*;

pub use update_metadata_request::*;

pub use update_metadata_response::*;

pub use update_raft_voter_request::*;

pub use update_raft_voter_response::*;

pub use vote_request::*;

pub use vote_response::*;

pub use voters_record::*;

pub use write_share_group_state_request::*;

pub use write_share_group_state_response::*;

pub use write_txn_markers_request::*;

pub use write_txn_markers_response::*;

Modules

add_offsets_to_txn_request

Generated from AddOffsetsToTxnRequest.json - DO NOT EDIT

add_offsets_to_txn_response

Generated from AddOffsetsToTxnResponse.json - DO NOT EDIT

add_partitions_to_txn_request

Generated from AddPartitionsToTxnRequest.json - DO NOT EDIT

add_partitions_to_txn_response

Generated from AddPartitionsToTxnResponse.json - DO NOT EDIT

add_raft_voter_request

Generated from AddRaftVoterRequest.json - DO NOT EDIT

add_raft_voter_response

Generated from AddRaftVoterResponse.json - DO NOT EDIT

allocate_producer_ids_request

Generated from AllocateProducerIdsRequest.json - DO NOT EDIT

allocate_producer_ids_response

Generated from AllocateProducerIdsResponse.json - DO NOT EDIT

alter_client_quotas_request

Generated from AlterClientQuotasRequest.json - DO NOT EDIT

alter_client_quotas_response

Generated from AlterClientQuotasResponse.json - DO NOT EDIT

alter_configs_request

Generated from AlterConfigsRequest.json - DO NOT EDIT

alter_configs_response

Generated from AlterConfigsResponse.json - DO NOT EDIT

alter_partition_reassignments_request

Generated from AlterPartitionReassignmentsRequest.json - DO NOT EDIT

alter_partition_reassignments_response

Generated from AlterPartitionReassignmentsResponse.json - DO NOT EDIT

alter_partition_request

Generated from AlterPartitionRequest.json - DO NOT EDIT

alter_partition_response

Generated from AlterPartitionResponse.json - DO NOT EDIT

alter_replica_log_dirs_request

Generated from AlterReplicaLogDirsRequest.json - DO NOT EDIT

alter_replica_log_dirs_response

Generated from AlterReplicaLogDirsResponse.json - DO NOT EDIT

alter_share_group_offsets_request

Generated from AlterShareGroupOffsetsRequest.json - DO NOT EDIT

alter_share_group_offsets_response

Generated from AlterShareGroupOffsetsResponse.json - DO NOT EDIT

alter_user_scram_credentials_request

Generated from AlterUserScramCredentialsRequest.json - DO NOT EDIT

alter_user_scram_credentials_response

Generated from AlterUserScramCredentialsResponse.json - DO NOT EDIT

api_versions_request

Generated from ApiVersionsRequest.json - DO NOT EDIT

api_versions_response

Generated from ApiVersionsResponse.json - DO NOT EDIT

assign_replicas_to_dirs_request

Generated from AssignReplicasToDirsRequest.json - DO NOT EDIT

assign_replicas_to_dirs_response

Generated from AssignReplicasToDirsResponse.json - DO NOT EDIT

begin_quorum_epoch_request

Generated from BeginQuorumEpochRequest.json - DO NOT EDIT

begin_quorum_epoch_response

Generated from BeginQuorumEpochResponse.json - DO NOT EDIT

broker_heartbeat_request

Generated from BrokerHeartbeatRequest.json - DO NOT EDIT

broker_heartbeat_response

Generated from BrokerHeartbeatResponse.json - DO NOT EDIT

broker_registration_request

Generated from BrokerRegistrationRequest.json - DO NOT EDIT

broker_registration_response

Generated from BrokerRegistrationResponse.json - DO NOT EDIT

consumer_group_describe_request

Generated from ConsumerGroupDescribeRequest.json - DO NOT EDIT

consumer_group_describe_response

Generated from ConsumerGroupDescribeResponse.json - DO NOT EDIT

consumer_group_heartbeat_request

Generated from ConsumerGroupHeartbeatRequest.json - DO NOT EDIT

consumer_group_heartbeat_response

Generated from ConsumerGroupHeartbeatResponse.json - DO NOT EDIT

consumer_protocol_assignment

Generated from ConsumerProtocolAssignment.json - DO NOT EDIT

consumer_protocol_subscription

Generated from ConsumerProtocolSubscription.json - DO NOT EDIT

control_record_type_schema

Generated from ControlRecordTypeSchema.json - DO NOT EDIT

controlled_shutdown_request

Generated from ControlledShutdownRequest.json - DO NOT EDIT

controlled_shutdown_response

Generated from ControlledShutdownResponse.json - DO NOT EDIT

controller_registration_request

Generated from ControllerRegistrationRequest.json - DO NOT EDIT

controller_registration_response

Generated from ControllerRegistrationResponse.json - DO NOT EDIT

create_acls_request

Generated from CreateAclsRequest.json - DO NOT EDIT

create_acls_response

Generated from CreateAclsResponse.json - DO NOT EDIT

create_delegation_token_request

Generated from CreateDelegationTokenRequest.json - DO NOT EDIT

create_delegation_token_response

Generated from CreateDelegationTokenResponse.json - DO NOT EDIT

create_partitions_request

Generated from CreatePartitionsRequest.json - DO NOT EDIT

create_partitions_response

Generated from CreatePartitionsResponse.json - DO NOT EDIT

create_topics_request

Generated from CreateTopicsRequest.json - DO NOT EDIT

create_topics_response

Generated from CreateTopicsResponse.json - DO NOT EDIT

default_principal_data

Generated from DefaultPrincipalData.json - DO NOT EDIT

delete_acls_request

Generated from DeleteAclsRequest.json - DO NOT EDIT

delete_acls_response

Generated from DeleteAclsResponse.json - DO NOT EDIT

delete_groups_request

Generated from DeleteGroupsRequest.json - DO NOT EDIT

delete_groups_response

Generated from DeleteGroupsResponse.json - DO NOT EDIT

delete_records_request

Generated from DeleteRecordsRequest.json - DO NOT EDIT

delete_records_response

Generated from DeleteRecordsResponse.json - DO NOT EDIT

delete_share_group_offsets_request

Generated from DeleteShareGroupOffsetsRequest.json - DO NOT EDIT

delete_share_group_offsets_response

Generated from DeleteShareGroupOffsetsResponse.json - DO NOT EDIT

delete_share_group_state_request

Generated from DeleteShareGroupStateRequest.json - DO NOT EDIT

delete_share_group_state_response

Generated from DeleteShareGroupStateResponse.json - DO NOT EDIT

delete_topics_request

Generated from DeleteTopicsRequest.json - DO NOT EDIT

delete_topics_response

Generated from DeleteTopicsResponse.json - DO NOT EDIT

describe_acls_request

Generated from DescribeAclsRequest.json - DO NOT EDIT

describe_acls_response

Generated from DescribeAclsResponse.json - DO NOT EDIT

describe_client_quotas_request

Generated from DescribeClientQuotasRequest.json - DO NOT EDIT

describe_client_quotas_response

Generated from DescribeClientQuotasResponse.json - DO NOT EDIT

describe_cluster_request

Generated from DescribeClusterRequest.json - DO NOT EDIT

describe_cluster_response

Generated from DescribeClusterResponse.json - DO NOT EDIT

describe_configs_request

Generated from DescribeConfigsRequest.json - DO NOT EDIT

describe_configs_response

Generated from DescribeConfigsResponse.json - DO NOT EDIT

describe_delegation_token_request

Generated from DescribeDelegationTokenRequest.json - DO NOT EDIT

describe_delegation_token_response

Generated from DescribeDelegationTokenResponse.json - DO NOT EDIT

describe_groups_request

Generated from DescribeGroupsRequest.json - DO NOT EDIT

describe_groups_response

Generated from DescribeGroupsResponse.json - DO NOT EDIT

describe_log_dirs_request

Generated from DescribeLogDirsRequest.json - DO NOT EDIT

describe_log_dirs_response

Generated from DescribeLogDirsResponse.json - DO NOT EDIT

describe_producers_request

Generated from DescribeProducersRequest.json - DO NOT EDIT

describe_producers_response

Generated from DescribeProducersResponse.json - DO NOT EDIT

describe_quorum_request

Generated from DescribeQuorumRequest.json - DO NOT EDIT

describe_quorum_response

Generated from DescribeQuorumResponse.json - DO NOT EDIT

describe_share_group_offsets_request

Generated from DescribeShareGroupOffsetsRequest.json - DO NOT EDIT

describe_share_group_offsets_response

Generated from DescribeShareGroupOffsetsResponse.json - DO NOT EDIT

describe_topic_partitions_request

Generated from DescribeTopicPartitionsRequest.json - DO NOT EDIT

describe_topic_partitions_response

Generated from DescribeTopicPartitionsResponse.json - DO NOT EDIT

describe_transactions_request

Generated from DescribeTransactionsRequest.json - DO NOT EDIT

describe_transactions_response

Generated from DescribeTransactionsResponse.json - DO NOT EDIT

describe_user_scram_credentials_request

Generated from DescribeUserScramCredentialsRequest.json - DO NOT EDIT

describe_user_scram_credentials_response

Generated from DescribeUserScramCredentialsResponse.json - DO NOT EDIT

elect_leaders_request

Generated from ElectLeadersRequest.json - DO NOT EDIT

elect_leaders_response

Generated from ElectLeadersResponse.json - DO NOT EDIT

end_quorum_epoch_request

Generated from EndQuorumEpochRequest.json - DO NOT EDIT

end_quorum_epoch_response

Generated from EndQuorumEpochResponse.json - DO NOT EDIT

end_txn_marker

Generated from EndTxnMarker.json - DO NOT EDIT

end_txn_request

Generated from EndTxnRequest.json - DO NOT EDIT

end_txn_response

Generated from EndTxnResponse.json - DO NOT EDIT

envelope_request

Generated from EnvelopeRequest.json - DO NOT EDIT

envelope_response

Generated from EnvelopeResponse.json - DO NOT EDIT

error_code

Kafka protocol error codes.

expire_delegation_token_request

Generated from ExpireDelegationTokenRequest.json - DO NOT EDIT

expire_delegation_token_response

Generated from ExpireDelegationTokenResponse.json - DO NOT EDIT

fetch_request

Generated from FetchRequest.json - DO NOT EDIT

fetch_response

Generated from FetchResponse.json - DO NOT EDIT

fetch_snapshot_request

Generated from FetchSnapshotRequest.json - DO NOT EDIT

fetch_snapshot_response

Generated from FetchSnapshotResponse.json - DO NOT EDIT

find_coordinator_request

Generated from FindCoordinatorRequest.json - DO NOT EDIT

find_coordinator_response

Generated from FindCoordinatorResponse.json - DO NOT EDIT

get_telemetry_subscriptions_request

Generated from GetTelemetrySubscriptionsRequest.json - DO NOT EDIT

get_telemetry_subscriptions_response

Generated from GetTelemetrySubscriptionsResponse.json - DO NOT EDIT

heartbeat_request

Generated from HeartbeatRequest.json - DO NOT EDIT

heartbeat_response

Generated from HeartbeatResponse.json - DO NOT EDIT

incremental_alter_configs_request

Generated from IncrementalAlterConfigsRequest.json - DO NOT EDIT

incremental_alter_configs_response

Generated from IncrementalAlterConfigsResponse.json - DO NOT EDIT

init_producer_id_request

Generated from InitProducerIdRequest.json - DO NOT EDIT

init_producer_id_response

Generated from InitProducerIdResponse.json - DO NOT EDIT

initialize_share_group_state_request

Generated from InitializeShareGroupStateRequest.json - DO NOT EDIT

initialize_share_group_state_response

Generated from InitializeShareGroupStateResponse.json - DO NOT EDIT

join_group_request

Generated from JoinGroupRequest.json - DO NOT EDIT

join_group_response

Generated from JoinGroupResponse.json - DO NOT EDIT

k_raft_version_record

Generated from KRaftVersionRecord.json - DO NOT EDIT

leader_and_isr_request

Generated from LeaderAndIsrRequest.json - DO NOT EDIT

leader_and_isr_response

Generated from LeaderAndIsrResponse.json - DO NOT EDIT

leader_change_message

Generated from LeaderChangeMessage.json - DO NOT EDIT

leave_group_request

Generated from LeaveGroupRequest.json - DO NOT EDIT

leave_group_response

Generated from LeaveGroupResponse.json - DO NOT EDIT

list_config_resources_request

Generated from ListConfigResourcesRequest.json - DO NOT EDIT

list_config_resources_response

Generated from ListConfigResourcesResponse.json - DO NOT EDIT

list_groups_request

Generated from ListGroupsRequest.json - DO NOT EDIT

list_groups_response

Generated from ListGroupsResponse.json - DO NOT EDIT

list_offsets_request

Generated from ListOffsetsRequest.json - DO NOT EDIT

list_offsets_response

Generated from ListOffsetsResponse.json - DO NOT EDIT

list_partition_reassignments_request

Generated from ListPartitionReassignmentsRequest.json - DO NOT EDIT

list_partition_reassignments_response

Generated from ListPartitionReassignmentsResponse.json - DO NOT EDIT

list_transactions_request

Generated from ListTransactionsRequest.json - DO NOT EDIT

list_transactions_response

Generated from ListTransactionsResponse.json - DO NOT EDIT

metadata_request

Generated from MetadataRequest.json - DO NOT EDIT

metadata_response

Generated from MetadataResponse.json - DO NOT EDIT

offset_commit_request

Generated from OffsetCommitRequest.json - DO NOT EDIT

offset_commit_response

Generated from OffsetCommitResponse.json - DO NOT EDIT

offset_delete_request

Generated from OffsetDeleteRequest.json - DO NOT EDIT

offset_delete_response

Generated from OffsetDeleteResponse.json - DO NOT EDIT

offset_fetch_request

Generated from OffsetFetchRequest.json - DO NOT EDIT

offset_fetch_response

Generated from OffsetFetchResponse.json - DO NOT EDIT

offset_for_leader_epoch_request

Generated from OffsetForLeaderEpochRequest.json - DO NOT EDIT

offset_for_leader_epoch_response

Generated from OffsetForLeaderEpochResponse.json - DO NOT EDIT

produce_request

Generated from ProduceRequest.json - DO NOT EDIT

produce_response

Generated from ProduceResponse.json - DO NOT EDIT

push_telemetry_request

Generated from PushTelemetryRequest.json - DO NOT EDIT

push_telemetry_response

Generated from PushTelemetryResponse.json - DO NOT EDIT

read_share_group_state_request

Generated from ReadShareGroupStateRequest.json - DO NOT EDIT

read_share_group_state_response

Generated from ReadShareGroupStateResponse.json - DO NOT EDIT

read_share_group_state_summary_request

Generated from ReadShareGroupStateSummaryRequest.json - DO NOT EDIT

read_share_group_state_summary_response

Generated from ReadShareGroupStateSummaryResponse.json - DO NOT EDIT

remove_raft_voter_request

Generated from RemoveRaftVoterRequest.json - DO NOT EDIT

remove_raft_voter_response

Generated from RemoveRaftVoterResponse.json - DO NOT EDIT

renew_delegation_token_request

Generated from RenewDelegationTokenRequest.json - DO NOT EDIT

renew_delegation_token_response

Generated from RenewDelegationTokenResponse.json - DO NOT EDIT

request_header

Generated from RequestHeader.json - DO NOT EDIT

response_header

Generated from ResponseHeader.json - DO NOT EDIT

sasl_authenticate_request

Generated from SaslAuthenticateRequest.json - DO NOT EDIT

sasl_authenticate_response

Generated from SaslAuthenticateResponse.json - DO NOT EDIT

sasl_handshake_request

Generated from SaslHandshakeRequest.json - DO NOT EDIT

sasl_handshake_response

Generated from SaslHandshakeResponse.json - DO NOT EDIT

share_acknowledge_request

Generated from ShareAcknowledgeRequest.json - DO NOT EDIT

share_acknowledge_response

Generated from ShareAcknowledgeResponse.json - DO NOT EDIT

share_fetch_request

Generated from ShareFetchRequest.json - DO NOT EDIT

share_fetch_response

Generated from ShareFetchResponse.json - DO NOT EDIT

share_group_describe_request

Generated from ShareGroupDescribeRequest.json - DO NOT EDIT

share_group_describe_response

Generated from ShareGroupDescribeResponse.json - DO NOT EDIT

share_group_heartbeat_request

Generated from ShareGroupHeartbeatRequest.json - DO NOT EDIT

share_group_heartbeat_response

Generated from ShareGroupHeartbeatResponse.json - DO NOT EDIT

snapshot_footer_record

Generated from SnapshotFooterRecord.json - DO NOT EDIT

snapshot_header_record

Generated from SnapshotHeaderRecord.json - DO NOT EDIT

stop_replica_request

Generated from StopReplicaRequest.json - DO NOT EDIT

stop_replica_response

Generated from StopReplicaResponse.json - DO NOT EDIT

streams_group_describe_request

Generated from StreamsGroupDescribeRequest.json - DO NOT EDIT

streams_group_describe_response

Generated from StreamsGroupDescribeResponse.json - DO NOT EDIT

streams_group_heartbeat_request

Generated from StreamsGroupHeartbeatRequest.json - DO NOT EDIT

streams_group_heartbeat_response

Generated from StreamsGroupHeartbeatResponse.json - DO NOT EDIT

sync_group_request

Generated from SyncGroupRequest.json - DO NOT EDIT

sync_group_response

Generated from SyncGroupResponse.json - DO NOT EDIT

txn_offset_commit_request

Generated from TxnOffsetCommitRequest.json - DO NOT EDIT

txn_offset_commit_response

Generated from TxnOffsetCommitResponse.json - DO NOT EDIT

unregister_broker_request

Generated from UnregisterBrokerRequest.json - DO NOT EDIT

unregister_broker_response

Generated from UnregisterBrokerResponse.json - DO NOT EDIT

update_features_request

Generated from UpdateFeaturesRequest.json - DO NOT EDIT

update_features_response

Generated from UpdateFeaturesResponse.json - DO NOT EDIT

update_metadata_request

Generated from UpdateMetadataRequest.json - DO NOT EDIT

update_metadata_response

Generated from UpdateMetadataResponse.json - DO NOT EDIT

update_raft_voter_request

Generated from UpdateRaftVoterRequest.json - DO NOT EDIT

update_raft_voter_response

Generated from UpdateRaftVoterResponse.json - DO NOT EDIT

vote_request

Generated from VoteRequest.json - DO NOT EDIT

vote_response

Generated from VoteResponse.json - DO NOT EDIT

voters_record

Generated from VotersRecord.json - DO NOT EDIT

write_share_group_state_request

Generated from WriteShareGroupStateRequest.json - DO NOT EDIT

write_share_group_state_response

Generated from WriteShareGroupStateResponse.json - DO NOT EDIT

write_txn_markers_request

Generated from WriteTxnMarkersRequest.json - DO NOT EDIT

write_txn_markers_response

Generated from WriteTxnMarkersResponse.json - DO NOT EDIT

Structs

ApiInfo

Static metadata about a Kafka API: supported version range and flexible-encoding threshold.

Enums

ApiKey

Kafka API keys for request dispatch.

Constants

KAFKA_PROTOCOL_SOURCE_REF

Functions

client_api_info

Returns the client-side ApiInfo for the given ApiKey.