List of all items

Structs

• codec::RawTaggedField
• records::Header
• records::MutableRecordBatch
• records::Record
• records::RecordBatch
• records::RecordBatchView
• records::RecordBatches
• schemata::api_versions_request::ApiVersionsRequest
• schemata::api_versions_response::ApiVersion
• schemata::api_versions_response::ApiVersionsResponse
• schemata::api_versions_response::FinalizedFeatureKey
• schemata::api_versions_response::SupportedFeatureKey
• schemata::apikey::ApiMessageType
• schemata::create_topic_request::CreatableReplicaAssignment
• schemata::create_topic_request::CreatableTopic
• schemata::create_topic_request::CreatableTopicConfig
• schemata::create_topic_request::CreateTopicsRequest
• schemata::create_topic_response::CreatableTopicConfigs
• schemata::create_topic_response::CreatableTopicResult
• schemata::create_topic_response::CreateTopicsResponse
• schemata::error::ErrorCode
• schemata::fetch_request::FetchPartition
• schemata::fetch_request::FetchRequest
• schemata::fetch_request::FetchTopic
• schemata::fetch_request::ForgottenTopic
• schemata::fetch_request::ReplicaState
• schemata::fetch_response::AbortedTransaction
• schemata::fetch_response::EpochEndOffset
• schemata::fetch_response::FetchResponse
• schemata::fetch_response::FetchableTopicResponse
• schemata::fetch_response::LeaderIdAndEpoch
• schemata::fetch_response::PartitionData
• schemata::fetch_response::SnapshotId
• schemata::find_coordinator_request::FindCoordinatorRequest
• schemata::find_coordinator_response::Coordinator
• schemata::find_coordinator_response::FindCoordinatorResponse
• schemata::heartbeat_request::HeartbeatRequest
• schemata::heartbeat_response::HeartbeatResponse
• schemata::init_producer_id_request::InitProducerIdRequest
• schemata::init_producer_id_response::InitProducerIdResponse
• schemata::join_group_request::JoinGroupRequest
• schemata::join_group_request::JoinGroupRequestProtocol
• schemata::join_group_response::JoinGroupResponse
• schemata::join_group_response::JoinGroupResponseMember
• schemata::metadata_request::MetadataRequest
• schemata::metadata_request::MetadataRequestTopic
• schemata::metadata_response::MetadataResponse
• schemata::metadata_response::MetadataResponseBroker
• schemata::metadata_response::MetadataResponsePartition
• schemata::metadata_response::MetadataResponseTopic
• schemata::offset_fetch_request::OffsetFetchRequest
• schemata::offset_fetch_request::OffsetFetchRequestGroup
• schemata::offset_fetch_request::OffsetFetchRequestTopic
• schemata::offset_fetch_response::OffsetFetchResponse
• schemata::offset_fetch_response::OffsetFetchResponseGroup
• schemata::offset_fetch_response::OffsetFetchResponsePartition
• schemata::offset_fetch_response::OffsetFetchResponsePartitions
• schemata::offset_fetch_response::OffsetFetchResponseTopic
• schemata::offset_fetch_response::OffsetFetchResponseTopics
• schemata::produce_request::PartitionProduceData
• schemata::produce_request::ProduceRequest
• schemata::produce_request::TopicProduceData
• schemata::produce_response::BatchIndexAndErrorMessage
• schemata::produce_response::PartitionProduceResponse
• schemata::produce_response::ProduceResponse
• schemata::produce_response::TopicProduceResponse
• schemata::request_header::RequestHeader
• schemata::response_header::ResponseHeader
• schemata::sync_group_request::SyncGroupRequest
• schemata::sync_group_request::SyncGroupRequestAssignment
• schemata::sync_group_response::SyncGroupResponse

Enums

• records::CompressionType
• records::TimestampType
• schemata::Request
• schemata::Response

Traits

• codec::Decodable
• codec::Encodable

Functions

• records::decrement_sequence
• records::increment_sequence

Constants

• records::ATTRIBUTES_OFFSET
• records::ATTRIBUTE_LENGTH
• records::BASE_OFFSET_LENGTH
• records::BASE_OFFSET_OFFSET
• records::BASE_SEQUENCE_LENGTH
• records::BASE_SEQUENCE_OFFSET
• records::BASE_TIMESTAMP_LENGTH
• records::BASE_TIMESTAMP_OFFSET
• records::COMPRESSION_CODEC_MASK
• records::CONTROL_FLAG_MASK
• records::CRC_LENGTH
• records::CRC_OFFSET
• records::DELETE_HORIZON_FLAG_MASK
• records::HEADER_SIZE_UP_TO_MAGIC
• records::LAST_OFFSET_DELTA_LENGTH
• records::LAST_OFFSET_DELTA_OFFSET
• records::LENGTH_LENGTH
• records::LENGTH_OFFSET
• records::LOG_OVERHEAD
• records::MAGIC_LENGTH
• records::MAGIC_OFFSET
• records::MAX_TIMESTAMP_LENGTH
• records::MAX_TIMESTAMP_OFFSET
• records::NO_SEQUENCE
• records::PARTITION_LEADER_EPOCH_LENGTH
• records::PARTITION_LEADER_EPOCH_OFFSET
• records::PRODUCER_EPOCH_LENGTH
• records::PRODUCER_EPOCH_OFFSET
• records::PRODUCER_ID_LENGTH
• records::PRODUCER_ID_OFFSET
• records::RECORDS_COUNT_LENGTH
• records::RECORDS_COUNT_OFFSET
• records::RECORDS_OFFSET
• records::RECORD_BATCH_OVERHEAD
• records::TIMESTAMP_TYPE_MASK
• records::TRANSACTIONAL_FLAG_MASK