List of all items

Structs

• client::CommitOffset
• client::FetchGroupOffset
• client::FetchPartition
• client::KafkaClient
• client::PartitionOffset
• client::ProduceConfirm
• client::ProduceMessage
• client::ProducePartitionConfirm
• client::SecurityConfig
• client::fetch::Data
• client::fetch::Message
• client::fetch::Partition
• client::fetch::Response
• client::fetch::Topic
• client::metadata::Broker
• client::metadata::Partition
• client::metadata::PartitionIter
• client::metadata::Partitions
• client::metadata::Topic
• client::metadata::TopicIter
• client::metadata::TopicNames
• client::metadata::Topics
• consumer::Builder
• consumer::Consumer
• consumer::MessageSet
• consumer::MessageSets
• consumer::MessageSetsIter
• producer::Builder
• producer::DefaultPartitioner
• producer::Partitions
• producer::Producer
• producer::Record
• producer::Topics

Enums

• client::Compression
• client::FetchOffset
• client::GroupOffsetStorage
• client::RequiredAcks
• error::Error
• error::KafkaCode

Traits

• producer::AsBytes
• producer::Partitioner

Type Aliases

• error::Result
• producer::DefaultHasher

Constants

• client::DEFAULT_COMPRESSION
• client::DEFAULT_CONNECTION_IDLE_TIMEOUT_MILLIS
• client::DEFAULT_FETCH_CRC_VALIDATION
• client::DEFAULT_FETCH_MAX_BYTES_PER_PARTITION
• client::DEFAULT_FETCH_MAX_WAIT_TIME_MILLIS
• client::DEFAULT_FETCH_MIN_BYTES
• client::DEFAULT_GROUP_OFFSET_STORAGE
• client::DEFAULT_RETRY_BACKOFF_TIME_MILLIS
• client::DEFAULT_RETRY_MAX_ATTEMPTS
• consumer::DEFAULT_FALLBACK_OFFSET
• consumer::DEFAULT_RETRY_MAX_BYTES_LIMIT
• producer::DEFAULT_ACK_TIMEOUT_MILLIS
• producer::DEFAULT_REQUIRED_ACKS