List of all items

Structs

• ErrorCode
• conn::Connection
• conn::PendingResponse
• consumer::AbortedTransaction
• consumer::FetchPosition
• consumer::Fetched
• frame::FrameDecoder
• group::CooperativeStickyAssignor
• group::RangeAssignor
• group::RoundRobinAssignor
• group::StickyAssignor
• group::Subscription
• group::TopicPartition
• member::GroupMember
• metadata::BrokerAddr
• metadata::Metadata
• producer::ProducerIdentity
• producer::ProducerState
• producer::SequenceRange
• records::LeanBatch
• records::LeanRecord

Enums

• Disposition
• Error
• consumer::IsolationLevel
• member::MemberState
• member::RebalanceProtocol
• member::Step
• partitioner::Partitioner
• producer::ProducerError
• producer::TxnState

Traits

• group::Assignor

Functions

• consumer::filter
• frame::frame
• partitioner::crc32
• partitioner::murmur2
• producer::looks_deduplicated
• records::decode_lean
• records::filter_batches

Type Aliases

• Result
• group::Assignment
• metadata::PartitionKey

Constants

• frame::DEFAULT_MAX_FRAME
• member::NO_GENERATION
• member::codes::COORDINATOR_LOAD_IN_PROGRESS
• member::codes::COORDINATOR_NOT_AVAILABLE
• member::codes::FENCED_INSTANCE_ID
• member::codes::ILLEGAL_GENERATION
• member::codes::MEMBER_ID_REQUIRED
• member::codes::NONE
• member::codes::NOT_COORDINATOR
• member::codes::REBALANCE_IN_PROGRESS
• member::codes::UNKNOWN_MEMBER_ID