List of all items
Structs
- BatchAttribute
- ControlBatch
- EndTransactionMarker
- Frame
- RootMessageMeta
- add_offsets_to_txn_request::AddOffsetsToTxnRequest
- add_offsets_to_txn_response::AddOffsetsToTxnResponse
- add_partitions_to_txn_request::AddPartitionsToTxnRequest
- add_partitions_to_txn_request::AddPartitionsToTxnTopic
- add_partitions_to_txn_request::AddPartitionsToTxnTransaction
- add_partitions_to_txn_response::AddPartitionsToTxnPartitionResult
- add_partitions_to_txn_response::AddPartitionsToTxnResponse
- add_partitions_to_txn_response::AddPartitionsToTxnResult
- add_partitions_to_txn_response::AddPartitionsToTxnTopicResult
- add_raft_voter_request::AddRaftVoterRequest
- add_raft_voter_request::Listener
- add_raft_voter_response::AddRaftVoterResponse
- alter_client_quotas_request::AlterClientQuotasRequest
- alter_client_quotas_request::EntityData
- alter_client_quotas_request::EntryData
- alter_client_quotas_request::OpData
- alter_client_quotas_response::AlterClientQuotasResponse
- alter_client_quotas_response::EntityData
- alter_client_quotas_response::EntryData
- alter_configs_request::AlterConfigsRequest
- alter_configs_request::AlterConfigsResource
- alter_configs_request::AlterableConfig
- alter_configs_response::AlterConfigsResourceResponse
- alter_configs_response::AlterConfigsResponse
- alter_partition_reassignments_request::AlterPartitionReassignmentsRequest
- alter_partition_reassignments_request::ReassignablePartition
- alter_partition_reassignments_request::ReassignableTopic
- alter_partition_reassignments_response::AlterPartitionReassignmentsResponse
- alter_partition_reassignments_response::ReassignablePartitionResponse
- alter_partition_reassignments_response::ReassignableTopicResponse
- alter_replica_log_dirs_request::AlterReplicaLogDir
- alter_replica_log_dirs_request::AlterReplicaLogDirTopic
- alter_replica_log_dirs_request::AlterReplicaLogDirsRequest
- alter_replica_log_dirs_response::AlterReplicaLogDirPartitionResult
- alter_replica_log_dirs_response::AlterReplicaLogDirTopicResult
- alter_replica_log_dirs_response::AlterReplicaLogDirsResponse
- alter_user_scram_credentials_request::AlterUserScramCredentialsRequest
- alter_user_scram_credentials_request::ScramCredentialDeletion
- alter_user_scram_credentials_request::ScramCredentialUpsertion
- alter_user_scram_credentials_response::AlterUserScramCredentialsResponse
- alter_user_scram_credentials_response::AlterUserScramCredentialsResult
- api_versions_request::ApiVersionsRequest
- api_versions_response::ApiVersion
- api_versions_response::ApiVersionsResponse
- api_versions_response::FinalizedFeatureKey
- api_versions_response::SupportedFeatureKey
- consumer_group_describe_request::ConsumerGroupDescribeRequest
- consumer_group_describe_response::Assignment
- consumer_group_describe_response::ConsumerGroupDescribeResponse
- consumer_group_describe_response::DescribedGroup
- consumer_group_describe_response::Member
- consumer_group_describe_response::TopicPartitions
- consumer_group_heartbeat_request::ConsumerGroupHeartbeatRequest
- consumer_group_heartbeat_request::TopicPartitions
- consumer_group_heartbeat_response::Assignment
- consumer_group_heartbeat_response::ConsumerGroupHeartbeatResponse
- consumer_group_heartbeat_response::TopicPartitions
- create_acls_request::AclCreation
- create_acls_request::CreateAclsRequest
- create_acls_response::AclCreationResult
- create_acls_response::CreateAclsResponse
- create_delegation_token_request::CreatableRenewers
- create_delegation_token_request::CreateDelegationTokenRequest
- create_delegation_token_response::CreateDelegationTokenResponse
- create_partitions_request::CreatePartitionsAssignment
- create_partitions_request::CreatePartitionsRequest
- create_partitions_request::CreatePartitionsTopic
- create_partitions_response::CreatePartitionsResponse
- create_partitions_response::CreatePartitionsTopicResult
- create_topics_request::CreatableReplicaAssignment
- create_topics_request::CreatableTopic
- create_topics_request::CreatableTopicConfig
- create_topics_request::CreateTopicsRequest
- create_topics_response::CreatableTopicConfigs
- create_topics_response::CreatableTopicResult
- create_topics_response::CreateTopicsResponse
- de::BatchDecoder
- de::Decoder
- delete_acls_request::DeleteAclsFilter
- delete_acls_request::DeleteAclsRequest
- delete_acls_response::DeleteAclsFilterResult
- delete_acls_response::DeleteAclsMatchingAcl
- delete_acls_response::DeleteAclsResponse
- delete_groups_request::DeleteGroupsRequest
- delete_groups_response::DeletableGroupResult
- delete_groups_response::DeleteGroupsResponse
- delete_records_request::DeleteRecordsPartition
- delete_records_request::DeleteRecordsRequest
- delete_records_request::DeleteRecordsTopic
- delete_records_response::DeleteRecordsPartitionResult
- delete_records_response::DeleteRecordsResponse
- delete_records_response::DeleteRecordsTopicResult
- delete_share_group_state_request::DeleteShareGroupStateRequest
- delete_share_group_state_request::DeleteStateData
- delete_share_group_state_request::PartitionData
- delete_share_group_state_response::DeleteShareGroupStateResponse
- delete_share_group_state_response::DeleteStateResult
- delete_share_group_state_response::PartitionResult
- delete_topics_request::DeleteTopicState
- delete_topics_request::DeleteTopicsRequest
- delete_topics_response::DeletableTopicResult
- delete_topics_response::DeleteTopicsResponse
- describe_acls_request::DescribeAclsRequest
- describe_acls_response::AclDescription
- describe_acls_response::DescribeAclsResource
- describe_acls_response::DescribeAclsResponse
- describe_client_quotas_request::ComponentData
- describe_client_quotas_request::DescribeClientQuotasRequest
- describe_client_quotas_response::DescribeClientQuotasResponse
- describe_client_quotas_response::EntityData
- describe_client_quotas_response::EntryData
- describe_client_quotas_response::ValueData
- describe_cluster_request::DescribeClusterRequest
- describe_cluster_response::DescribeClusterBroker
- describe_cluster_response::DescribeClusterResponse
- describe_configs_request::DescribeConfigsRequest
- describe_configs_request::DescribeConfigsResource
- describe_configs_response::DescribeConfigsResourceResult
- describe_configs_response::DescribeConfigsResponse
- describe_configs_response::DescribeConfigsResult
- describe_configs_response::DescribeConfigsSynonym
- describe_delegation_token_request::DescribeDelegationTokenOwner
- describe_delegation_token_request::DescribeDelegationTokenRequest
- describe_delegation_token_response::DescribeDelegationTokenResponse
- describe_delegation_token_response::DescribedDelegationToken
- describe_delegation_token_response::DescribedDelegationTokenRenewer
- describe_groups_request::DescribeGroupsRequest
- describe_groups_response::DescribeGroupsResponse
- describe_groups_response::DescribedGroup
- describe_groups_response::DescribedGroupMember
- describe_log_dirs_request::DescribableLogDirTopic
- describe_log_dirs_request::DescribeLogDirsRequest
- describe_log_dirs_response::DescribeLogDirsPartition
- describe_log_dirs_response::DescribeLogDirsResponse
- describe_log_dirs_response::DescribeLogDirsResult
- describe_log_dirs_response::DescribeLogDirsTopic
- describe_producers_request::DescribeProducersRequest
- describe_producers_request::TopicRequest
- describe_producers_response::DescribeProducersResponse
- describe_producers_response::PartitionResponse
- describe_producers_response::ProducerState
- describe_producers_response::TopicResponse
- describe_quorum_request::DescribeQuorumRequest
- describe_quorum_request::PartitionData
- describe_quorum_request::TopicData
- describe_quorum_response::DescribeQuorumResponse
- describe_quorum_response::Listener
- describe_quorum_response::Node
- describe_quorum_response::PartitionData
- describe_quorum_response::ReplicaState
- describe_quorum_response::TopicData
- describe_topic_partitions_request::Cursor
- describe_topic_partitions_request::DescribeTopicPartitionsRequest
- describe_topic_partitions_request::TopicRequest
- describe_topic_partitions_response::Cursor
- describe_topic_partitions_response::DescribeTopicPartitionsResponse
- describe_topic_partitions_response::DescribeTopicPartitionsResponsePartition
- describe_topic_partitions_response::DescribeTopicPartitionsResponseTopic
- describe_transactions_request::DescribeTransactionsRequest
- describe_transactions_response::DescribeTransactionsResponse
- describe_transactions_response::TopicData
- describe_transactions_response::TransactionState
- describe_user_scram_credentials_request::DescribeUserScramCredentialsRequest
- describe_user_scram_credentials_request::UserName
- describe_user_scram_credentials_response::CredentialInfo
- describe_user_scram_credentials_response::DescribeUserScramCredentialsResponse
- describe_user_scram_credentials_response::DescribeUserScramCredentialsResult
- elect_leaders_request::ElectLeadersRequest
- elect_leaders_request::TopicPartitions
- elect_leaders_response::ElectLeadersResponse
- elect_leaders_response::PartitionResult
- elect_leaders_response::ReplicaElectionResult
- end_txn_request::EndTxnRequest
- end_txn_response::EndTxnResponse
- expire_delegation_token_request::ExpireDelegationTokenRequest
- expire_delegation_token_response::ExpireDelegationTokenResponse
- fetch_request::FetchPartition
- fetch_request::FetchRequest
- fetch_request::FetchTopic
- fetch_request::ForgottenTopic
- fetch_request::ReplicaState
- fetch_response::AbortedTransaction
- fetch_response::EpochEndOffset
- fetch_response::FetchResponse
- fetch_response::FetchableTopicResponse
- fetch_response::LeaderIdAndEpoch
- fetch_response::NodeEndpoint
- fetch_response::PartitionData
- fetch_response::SnapshotId
- find_coordinator_request::FindCoordinatorRequest
- find_coordinator_response::Coordinator
- find_coordinator_response::FindCoordinatorResponse
- get_telemetry_subscriptions_request::GetTelemetrySubscriptionsRequest
- get_telemetry_subscriptions_response::GetTelemetrySubscriptionsResponse
- heartbeat_request::HeartbeatRequest
- heartbeat_response::HeartbeatResponse
- incremental_alter_configs_request::AlterConfigsResource
- incremental_alter_configs_request::AlterableConfig
- incremental_alter_configs_request::IncrementalAlterConfigsRequest
- incremental_alter_configs_response::AlterConfigsResourceResponse
- 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_request::InitializeStateData
- initialize_share_group_state_request::PartitionData
- initialize_share_group_state_response::InitializeShareGroupStateResponse
- initialize_share_group_state_response::InitializeStateResult
- initialize_share_group_state_response::PartitionResult
- join_group_request::JoinGroupRequest
- join_group_request::JoinGroupRequestProtocol
- join_group_response::JoinGroupResponse
- join_group_response::JoinGroupResponseMember
- leave_group_request::LeaveGroupRequest
- leave_group_request::MemberIdentity
- leave_group_response::LeaveGroupResponse
- leave_group_response::MemberResponse
- list_client_metrics_resources_response::ClientMetricsResource
- list_client_metrics_resources_response::ListClientMetricsResourcesResponse
- list_groups_request::ListGroupsRequest
- list_groups_response::ListGroupsResponse
- list_groups_response::ListedGroup
- list_offsets_request::ListOffsetsPartition
- list_offsets_request::ListOffsetsRequest
- list_offsets_request::ListOffsetsTopic
- list_offsets_response::ListOffsetsPartitionResponse
- list_offsets_response::ListOffsetsResponse
- list_offsets_response::ListOffsetsTopicResponse
- list_partition_reassignments_request::ListPartitionReassignmentsRequest
- list_partition_reassignments_request::ListPartitionReassignmentsTopics
- list_partition_reassignments_response::ListPartitionReassignmentsResponse
- list_partition_reassignments_response::OngoingPartitionReassignment
- list_partition_reassignments_response::OngoingTopicReassignment
- list_transactions_request::ListTransactionsRequest
- list_transactions_response::ListTransactionsResponse
- list_transactions_response::TransactionState
- metadata_request::MetadataRequest
- metadata_request::MetadataRequestTopic
- metadata_response::MetadataResponse
- metadata_response::MetadataResponseBroker
- metadata_response::MetadataResponsePartition
- metadata_response::MetadataResponseTopic
- offset_commit_request::OffsetCommitRequest
- offset_commit_request::OffsetCommitRequestPartition
- offset_commit_request::OffsetCommitRequestTopic
- offset_commit_response::OffsetCommitResponse
- offset_commit_response::OffsetCommitResponsePartition
- offset_commit_response::OffsetCommitResponseTopic
- offset_delete_request::OffsetDeleteRequest
- offset_delete_request::OffsetDeleteRequestPartition
- offset_delete_request::OffsetDeleteRequestTopic
- offset_delete_response::OffsetDeleteResponse
- offset_delete_response::OffsetDeleteResponsePartition
- offset_delete_response::OffsetDeleteResponseTopic
- offset_fetch_request::OffsetFetchRequest
- offset_fetch_request::OffsetFetchRequestGroup
- offset_fetch_request::OffsetFetchRequestTopic
- offset_fetch_request::OffsetFetchRequestTopics
- offset_fetch_response::OffsetFetchResponse
- offset_fetch_response::OffsetFetchResponseGroup
- offset_fetch_response::OffsetFetchResponsePartition
- offset_fetch_response::OffsetFetchResponsePartitions
- offset_fetch_response::OffsetFetchResponseTopic
- offset_fetch_response::OffsetFetchResponseTopics
- offset_for_leader_epoch_request::OffsetForLeaderEpochRequest
- offset_for_leader_epoch_request::OffsetForLeaderPartition
- offset_for_leader_epoch_request::OffsetForLeaderTopic
- offset_for_leader_epoch_response::EpochEndOffset
- offset_for_leader_epoch_response::OffsetForLeaderEpochResponse
- offset_for_leader_epoch_response::OffsetForLeaderTopicResult
- primitive::tagged::TagBuffer
- primitive::tagged::TagBufferBuilder
- primitive::tagged::TagField
- primitive::uuid::Uuid
- primitive::varint::LongVarInt
- primitive::varint::UnsignedVarInt
- primitive::varint::VarInt
- produce_request::PartitionProduceData
- produce_request::ProduceRequest
- produce_request::TopicProduceData
- produce_response::BatchIndexAndErrorMessage
- produce_response::LeaderIdAndEpoch
- produce_response::NodeEndpoint
- produce_response::PartitionProduceResponse
- produce_response::ProduceResponse
- produce_response::TopicProduceResponse
- push_telemetry_request::PushTelemetryRequest
- push_telemetry_response::PushTelemetryResponse
- read_share_group_state_request::PartitionData
- read_share_group_state_request::ReadShareGroupStateRequest
- read_share_group_state_request::ReadStateData
- read_share_group_state_response::PartitionResult
- read_share_group_state_response::ReadShareGroupStateResponse
- read_share_group_state_response::ReadStateResult
- read_share_group_state_response::StateBatch
- read_share_group_state_summary_request::PartitionData
- read_share_group_state_summary_request::ReadShareGroupStateSummaryRequest
- read_share_group_state_summary_request::ReadStateSummaryData
- read_share_group_state_summary_response::PartitionResult
- read_share_group_state_summary_response::ReadShareGroupStateSummaryResponse
- read_share_group_state_summary_response::ReadStateSummaryResult
- record::Builder
- record::Record
- record::deflated::Batch
- record::deflated::Frame
- record::header::Builder
- record::header::Header
- record::inflated::Batch
- record::inflated::Builder
- record::inflated::Compaction
- record::inflated::Frame
- remove_raft_voter_request::RemoveRaftVoterRequest
- remove_raft_voter_response::RemoveRaftVoterResponse
- renew_delegation_token_request::RenewDelegationTokenRequest
- renew_delegation_token_response::RenewDelegationTokenResponse
- sasl_authenticate_request::SaslAuthenticateRequest
- sasl_authenticate_response::SaslAuthenticateResponse
- sasl_handshake_request::SaslHandshakeRequest
- sasl_handshake_response::SaslHandshakeResponse
- ser::Encoder
- share_acknowledge_request::AcknowledgePartition
- share_acknowledge_request::AcknowledgeTopic
- share_acknowledge_request::AcknowledgementBatch
- share_acknowledge_request::ShareAcknowledgeRequest
- share_acknowledge_response::LeaderIdAndEpoch
- share_acknowledge_response::NodeEndpoint
- share_acknowledge_response::PartitionData
- share_acknowledge_response::ShareAcknowledgeResponse
- share_acknowledge_response::ShareAcknowledgeTopicResponse
- share_fetch_request::AcknowledgementBatch
- share_fetch_request::FetchPartition
- share_fetch_request::FetchTopic
- share_fetch_request::ForgottenTopic
- share_fetch_request::ShareFetchRequest
- share_fetch_response::AcquiredRecords
- share_fetch_response::LeaderIdAndEpoch
- share_fetch_response::NodeEndpoint
- share_fetch_response::PartitionData
- share_fetch_response::ShareFetchResponse
- share_fetch_response::ShareFetchableTopicResponse
- share_group_describe_request::ShareGroupDescribeRequest
- share_group_describe_response::Assignment
- share_group_describe_response::DescribedGroup
- share_group_describe_response::Member
- share_group_describe_response::ShareGroupDescribeResponse
- share_group_describe_response::TopicPartitions
- share_group_heartbeat_request::ShareGroupHeartbeatRequest
- share_group_heartbeat_response::Assignment
- share_group_heartbeat_response::ShareGroupHeartbeatResponse
- share_group_heartbeat_response::TopicPartitions
- sync_group_request::SyncGroupRequest
- sync_group_request::SyncGroupRequestAssignment
- sync_group_response::SyncGroupResponse
- txn_offset_commit_request::TxnOffsetCommitRequest
- txn_offset_commit_request::TxnOffsetCommitRequestPartition
- txn_offset_commit_request::TxnOffsetCommitRequestTopic
- txn_offset_commit_response::TxnOffsetCommitResponse
- txn_offset_commit_response::TxnOffsetCommitResponsePartition
- txn_offset_commit_response::TxnOffsetCommitResponseTopic
- unregister_broker_request::UnregisterBrokerRequest
- unregister_broker_response::UnregisterBrokerResponse
- update_features_request::FeatureUpdateKey
- update_features_request::UpdateFeaturesRequest
- update_features_response::UpdatableFeatureResult
- update_features_response::UpdateFeaturesResponse
- write_share_group_state_request::PartitionData
- write_share_group_state_request::StateBatch
- write_share_group_state_request::WriteShareGroupStateRequest
- write_share_group_state_request::WriteStateData
- write_share_group_state_response::PartitionResult
- write_share_group_state_response::WriteShareGroupStateResponse
- write_share_group_state_response::WriteStateResult
- write_txn_markers_request::WritableTxnMarker
- write_txn_markers_request::WritableTxnMarkerTopic
- write_txn_markers_request::WriteTxnMarkersRequest
- write_txn_markers_response::WritableTxnMarkerPartitionResult
- write_txn_markers_response::WritableTxnMarkerResult
- write_txn_markers_response::WritableTxnMarkerTopicResult
- write_txn_markers_response::WriteTxnMarkersResponse
Enums
- Ack
- Body
- Compression
- ConfigResource
- ConfigSource
- ConfigType
- CoordinatorType
- EndpointType
- Error
- ErrorCode
- Header
- IsolationLevel
- ListOffset
- OpType
- ScramMechanism
- TimestampType
- acl::Operation
- acl::Permission
- acl::Resource
- resource::Pattern