List of all items

Structs

• api::Assignment
• api::Batch
• api::GroupAssignment
• api::Metadata
• api::ProtocolMetadata
• api::Record
• api::RecordHeader
• api::RecordSet
• api::ReplicaKey
• api::RequestHeader
• api::RequestMessage
• api::ResponseMessage
• fs::KfFileRecordSet
• message::api_versions::ApiVersionsResponseKey
• message::api_versions::KfApiVersionsRequest
• message::api_versions::KfApiVersionsResponse
• message::fetch::AbortedTransaction
• message::fetch::FetchPartition
• message::fetch::FetchablePartitionResponse
• message::fetch::FetchableTopic
• message::fetch::FetchableTopicResponse
• message::fetch::ForgottenTopic
• message::fetch::KfFetchRequest
• message::fetch::KfFetchResponse
• message::group::DeletableGroupResult
• message::group::DescribedGroup
• message::group::DescribedGroupMember
• message::group::JoinGroupRequestProtocol
• message::group::JoinGroupResponseMember
• message::group::KfDeleteGroupsRequest
• message::group::KfDeleteGroupsResponse
• message::group::KfDescribeGroupsRequest
• message::group::KfDescribeGroupsResponse
• message::group::KfFindCoordinatorRequest
• message::group::KfFindCoordinatorResponse
• message::group::KfHeartbeatRequest
• message::group::KfHeartbeatResponse
• message::group::KfJoinGroupRequest
• message::group::KfJoinGroupResponse
• message::group::KfLeaveGroupRequest
• message::group::KfLeaveGroupResponse
• message::group::KfListGroupsRequest
• message::group::KfListGroupsResponse
• message::group::KfSyncGroupRequest
• message::group::KfSyncGroupResponse
• message::group::ListedGroup
• message::group::SyncGroupRequestAssignment
• message::isr::KfLeaderAndIsrRequest
• message::isr::KfLeaderAndIsrResponse
• message::isr::LeaderAndIsrLiveLeader
• message::isr::LeaderAndIsrRequestPartitionState
• message::isr::LeaderAndIsrRequestPartitionStateV0
• message::isr::LeaderAndIsrRequestTopicState
• message::isr::LeaderAndIsrResponsePartition
• message::metadata::KfMetadataRequest
• message::metadata::KfMetadataResponse
• message::metadata::KfUpdateMetadataRequest
• message::metadata::KfUpdateMetadataResponse
• message::metadata::MetadataRequestTopic
• message::metadata::MetadataResponseBroker
• message::metadata::MetadataResponsePartition
• message::metadata::MetadataResponseTopic
• message::metadata::UpdateMetadataPartitionState
• message::metadata::UpdateMetadataRequestBroker
• message::metadata::UpdateMetadataRequestEndpoint
• message::metadata::UpdateMetadataRequestPartitionStateV0
• message::metadata::UpdateMetadataRequestTopicState
• message::offset::KfListOffsetRequest
• message::offset::KfListOffsetResponse
• message::offset::KfOffsetFetchRequest
• message::offset::KfOffsetFetchResponse
• message::offset::ListOffsetPartition
• message::offset::ListOffsetPartitionResponse
• message::offset::ListOffsetTopic
• message::offset::ListOffsetTopicResponse
• message::offset::OffsetFetchRequestTopic
• message::offset::OffsetFetchResponsePartition
• message::offset::OffsetFetchResponseTopic
• message::produce::KfProduceRequest
• message::produce::KfProduceResponse
• message::produce::PartitionProduceData
• message::produce::PartitionProduceResponse
• message::produce::TopicProduceData
• message::produce::TopicProduceResponse
• message::topic::CreatableReplicaAssignment
• message::topic::CreatableTopic
• message::topic::CreatableTopicResult
• message::topic::CreateableTopicConfig
• message::topic::DeletableTopicResult
• message::topic::KfCreateTopicsRequest
• message::topic::KfCreateTopicsResponse
• message::topic::KfDeleteTopicsRequest
• message::topic::KfDeleteTopicsResponse
• transport::KfCodec

Enums

• api::AllKfApiKey
• api::ErrorCode
• api::FlvErrorCode
• api::Isolation
• api::PartitionError
• fs::StoreValue

Traits

• Decoder
• DecoderVarInt
• Encoder
• EncoderVarInt
• api::BatchRecords
• api::KfApiKey
• api::KfRequestMessage
• api::PartitionOffset
• api::Request
• bytes::Buf
• bytes::BufExt
• bytes::BufMut
• bytes::BufMutExt
• fs::FileWrite

Macros

• api::api_decode
• derive::kf_api

Derive Macros

• derive::Decode
• derive::Encode
• derive::KfDefault
• derive::RequestApi

Functions

• api::create_partition_name
• api::decompose_partition_name

Typedefs

• Version
• api::DefaultBatch
• api::DefaultBatchRecords
• api::DefaultRecord
• api::Offset
• api::Size
• fs::FileFetchResponse
• fs::FilePartitionRequest
• fs::FilePartitionResponse
• fs::FileProduceRequest
• fs::FileTopicRequest
• fs::FileTopicResponse
• fs::KfFileFetchRequest
• message::KfApiVersions
• message::fetch::DefaultKfFetchRequest
• message::fetch::DefaultKfFetchResponse
• message::fetch_handler::DefaultKfFetchRequest
• message::fetch_handler::DefaultKfFetchResponse
• message::produce::DefaultKfPartitionRequest
• message::produce::DefaultKfProduceRequest
• message::produce::DefaultKfTopicRequest
• message::produce_handler::DefaultKfPartitionRequest
• message::produce_handler::DefaultKfProduceRequest
• message::produce_handler::DefaultKfTopicRequest

Constants

• api::BATCH_HEADER_SIZE
• api::BATCH_PREAMBLE_SIZE
• api::MAX_BYTES