List of all items

Structs

• AcceptingListener
• AppData
• AppDataResponse
• ConnectionGuard
• ConnectionLimiter
• ConnectionLimits
• ConnectionQuotaSettings
• ConnectionQuotas
• Controller
• ControllerAdminRequest
• ControllerAdminResponse
• ControllerApiVersion
• ControllerConfig
• ControllerFetchMissLimit
• ControllerHandle
• KrabkaMetadataFetchRequest
• KrabkaMetadataFetchResponse
• KrabkaSubmitChangeRequest
• KrabkaSubmitChangeResponse
• ListenerLimits
• MetadataLogConfig
• MetadataRaftCommandQueueCapacity
• MetadataRaftFetchMax
• Node
• NodeId
• ObservedStream
• OffsetReservation
• PlaintextDialer
• QuorumState
• QuorumStateSnapshot
• ReleasedApi
• SnapshotSlice
• SubmitChangeResult
• event_queue::NoEventQueueRecorder
• handshake::AllowAllGrants
• handshake::HandshakeClock
• handshake::RaftConnection
• kraft::LogOffsetMetadata
• kraft::NodeId
• kraft::QuorumState
• kraft::QuorumStateMachine
• kraft::QuorumTimeouts
• kraft::ReplicaKey
• kraft::SimInstant
• kraft::controller::Activation
• kraft::controller::KraftConfig
• kraft::controller::KraftController
• kraft::core::QuorumStateMachine
• kraft::core::QuorumTimeouts
• kraft::event::LogEnd
• kraft::event::SuccessorRank
• kraft::log::KraftLog
• kraft::role::ReplicaProgress
• kraft::snapshot_fetch::MetadataSnapshotFetchMax
• kraft::snapshot_fetch::SnapshotFetchState
• kraft::transport::CommandSender
• kraft::transport::MetadataFetchSlice
• kraft::transport::NullPeerSender
• kraft::transport::ObserverReplica
• kraft::transport::QueuedCommand
• kraft::transport::QuorumStateSnapshot
• kraft::transport::wire::FetchAnswer
• kraft::transport::wire::FetchSnapshotPartition
• kraft::transport::wire::LeaderEndpoint
• kraft::transport::wire::PreferredCandidate
• kraft::transport::wire::QuorumLeader
• kraft::transport::wire::SnapshotChunk
• kraft::types::LogOffsetMetadata
• kraft::types::NodeId
• kraft::types::QuorumState
• kraft::types::ReplicaKey
• kraft::types::SimInstant
• reconfig::AddVoter
• reconfig::RemoveVoter
• reconfig::UpdateVoter
• voter_requests::ListenerAddress

Enums

• BootstrapMode
• ConnectionLimit
• DelegationTokenMutation
• MetadataReplayError
• PersistedFormatError
• RaftError
• SnapshotRange
• UnstableApiVersions
• UnstableFeatureVersions
• handshake::ClusterOperation
• handshake::RaftHandshakeError
• kraft::Action
• kraft::Event
• kraft::Role
• kraft::action::Action
• kraft::action::TimerKind
• kraft::event::Event
• kraft::role::Role
• kraft::snapshot_fetch::SnapshotFetchStep
• kraft::transport::Command
• kraft::transport::Inbound
• kraft::transport::TimerTick
• kraft::transport::api_key::PeerApi
• kraft::transport::wire::PeerRequest
• kraft::transport::wire::PeerResponse
• reconfig::ReconfigOutcome
• reconfig::VoterChange
• voter_requests::VoterOperation

Traits

• ControllerAdminRouter
• OutboundDialer
• RaftShardRouter
• RegistrationAdmission
• StreamObserver
• event_queue::EventQueueRecorder
• handshake::ClusterGrants
• handshake::ControllerApiVersions
• handshake::RaftListenerHandshake
• kraft::LogView
• kraft::transport::PeerSender
• kraft::types::LogView

Functions

• api_versions_max_version
• describe_quorum
• deserialize_metadata_snapshot
• deserialize_metadata_snapshot_image
• fetch_error_response
• finalized_feature_keys
• is_valid_api_versions_request
• is_valid_client_info
• kafka_4_3_1_api
• kafka_4_3_1_max
• kraft::controller::checkpoint::checkpoint_id_is_newer
• kraft::controller::checkpoint::latest_checkpoint_id
• kraft::controller::checkpoint::load_checkpoint_by_id
• kraft::controller::checkpoint::load_latest_checkpoint
• kraft::controller::checkpoint::retain_latest_checkpoint
• kraft::controller::checkpoint::retain_recent_checkpoints
• kraft::controller::checkpoint::write_checkpoint
• kraft::controller::control_batch_image_records
• kraft::controller::decode_committed_value
• kraft::controller::is_kip835_noop
• kraft::core::election_jitter_ms
• kraft::log::end_offset_for_epoch_in
• kraft::log::latest_epoch_in
• kraft::transport::wire::decode_begin
• kraft::transport::wire::decode_end
• kraft::transport::wire::decode_fetch
• kraft::transport::wire::decode_fetch_snapshot
• kraft::transport::wire::decode_vote
• kraft::transport::wire::encode_begin_quorum_epoch_response
• kraft::transport::wire::encode_end_quorum_epoch_response
• kraft::transport::wire::encode_fetch_snapshot_answer
• kraft::transport::wire::encode_fetch_top_level_error
• kraft::transport::wire::encode_vote_response
• kraft::transport::wire::fetch_replica_id
• metadata_log_nonempty
• metadata_partition_dir
• metadata_snapshot_last_contained_log_timestamp
• private_api_highest_version
• private_request_version
• serialize_bootstrap_snapshot
• serialize_metadata_snapshot
• supported_feature_key
• supported_feature_keys
• supported_feature_range
• supported_feature_ranges
• unsupported_version_response
• voter_requests::add_voter_refusal
• voter_requests::candidate_kraft_version_refusal
• voter_requests::candidate_unavailable_refusal
• voter_requests::leader_listener_name
• voter_requests::reconfiguration_refusal
• voter_requests::remove_voter_refusal
• voter_requests::replica_key
• voter_requests::update_voter_current_leader
• voter_requests::update_voter_refusal
• voter_requests::valid_wire_listeners

Type Aliases

• ControllerAdminRouteFuture
• IpOverrides
• RegistrationAdmissionFuture
• ShardRouteFuture
• handshake::HandshakeStream
• kraft::Epoch
• kraft::snapshot_fetch::SnapshotId
• kraft::types::Epoch
• voter_requests::Refusal

Constants

• API_KEY_DELEGATION_TOKEN_MUTATION
• API_KEY_METADATA_FETCH
• API_KEY_SUBMIT_CHANGE
• DEFAULT_METADATA_LOG_SEGMENT_ROLL_INTERVAL
• DEFAULT_METADATA_LOG_SEGMENT_SIZE
• DEFAULT_METADATA_MAX_IDLE_INTERVAL
• DEFAULT_METADATA_MAX_RETENTION
• DEFAULT_METADATA_MAX_RETENTION_SIZE
• KAFKA_4_3_1_APIS
• LATEST_PRODUCTION_METADATA_VERSION
• MAX_CONNECTIONS
• MAX_CONNECTIONS_PER_IP
• MAX_CONNECTIONS_PER_IP_OVERRIDES
• MAX_CONNECTION_CREATION_RATE
• METADATA_PARTITION_DIR
• MIN_METADATA_LOG_SEGMENT_SIZE
• PRIVATE_BASELINE_VERSION
• PRIVATE_CLUSTER_AUTHORIZATION_FAILED
• PRIVATE_UNSUPPORTED_VERSION
• SUBMIT_CHANGE_UNCOMMITTED_TAIL
• kraft::snapshot_fetch::METADATA_SNAPSHOT_FETCH_HARD_MAX
• kraft::transport::api_key::BEGIN_QUORUM_EPOCH
• kraft::transport::api_key::END_QUORUM_EPOCH
• kraft::transport::api_key::FETCH
• kraft::transport::api_key::FETCH_SNAPSHOT
• kraft::transport::api_key::VOTE
• kraft::transport::wire::FETCH_SNAPSHOT_VERSION
• kraft::transport::wire::FETCH_VERSION
• kraft::transport::wire::QUORUM_EPOCH_VERSION
• kraft::transport::wire::VOTE_VERSION
• voter_requests::DUPLICATE_VOTER
• voter_requests::FENCED_LEADER_EPOCH
• voter_requests::INCONSISTENT_CLUSTER_ID
• voter_requests::INVALID_REQUEST
• voter_requests::NOT_LEADER_OR_FOLLOWER
• voter_requests::REQUEST_TIMED_OUT
• voter_requests::UNKNOWN_LEADER_EPOCH
• voter_requests::UNKNOWN_SERVER_ERROR
• voter_requests::UNSUPPORTED_VERSION
• voter_requests::VOTER_NOT_FOUND