List of all items

Structs

• AuthConfig
• ClientConfig
• CommitResult
• Consumer
• ConsumerConfig
• FetchResult
• LanceClient
• PollResult
• StreamingConsumer
• StreamingConsumerConfig
• SubscribeResult
• TopicInfo
• connection::ClusterClient
• connection::ConnectionPool
• connection::ConnectionPoolConfig
• connection::PoolStats
• connection::PooledClient
• connection::ReconnectingClient
• grouped::GroupConfig
• grouped::GroupCoordinator
• grouped::GroupedConsumer
• grouped::WorkerConfig
• offset::CollectingCommitHook
• offset::CommitInfo
• offset::HookedOffsetStore
• offset::LockFileOffsetStore
• offset::LoggingCommitHook
• offset::MemoryOffsetStore
• producer::MetricsSnapshot
• producer::Producer
• producer::ProducerConfig
• producer::ProducerMetrics
• producer::SendAck
• record::Record
• record::RecordIterator
• record::RecordParserConfig
• standalone::StandaloneConfig
• standalone::StandaloneConsumer
• standalone::StandaloneConsumerBuilder
• tls::TlsClientConfig

Enums

• ClientError
• ClientStream
• SeekPosition
• grouped::AssignmentStrategy
• record::RecordParseError
• record::RecordType

Traits

• offset::OffsetStore
• offset::PostCommitHook

Functions

• parse_not_leader_error
• record::encode_record
• record::encode_record_with_type
• record::parse_record
• record::parse_records

Type Aliases

• producer::SendResult

Constants

• record::TLV_HEADER_SIZE