List of all items
Structs
- client::Client
- client::ClientBuilder
- client::consumer::StreamConsumer
- client::consumer::StreamConsumerBuilder
- client::controller::ControllerClient
- client::partition::PartitionClient
- client::producer::BatchProducer
- client::producer::BatchProducerBuilder
- client::producer::aggregator::RecordAggregator
- client::producer::aggregator::RecordAggregatorStatusDeaggregator
- messenger::Messenger
- protocol::api_version::ApiVersion
- protocol::api_version::ApiVersionRange
- protocol::messages::ApiVersionsRequest
- protocol::messages::ApiVersionsResponse
- protocol::messages::ApiVersionsResponseApiKey
- protocol::messages::CreateTopicAssignment
- protocol::messages::CreateTopicConfig
- protocol::messages::CreateTopicRequest
- protocol::messages::CreateTopicResponse
- protocol::messages::CreateTopicResponseConfig
- protocol::messages::CreateTopicsRequest
- protocol::messages::CreateTopicsResponse
- protocol::messages::DeleteRecordsRequest
- protocol::messages::DeleteRecordsResponse
- protocol::messages::DeleteRequestPartition
- protocol::messages::DeleteRequestTopic
- protocol::messages::DeleteResponsePartition
- protocol::messages::DeleteResponseTopic
- protocol::messages::DeleteTopicsRequest
- protocol::messages::DeleteTopicsResponse
- protocol::messages::DeleteTopicsResponseTopic
- protocol::messages::FetchRequest
- protocol::messages::FetchRequestPartition
- protocol::messages::FetchRequestTopic
- protocol::messages::FetchResponse
- protocol::messages::FetchResponseAbortedTransaction
- protocol::messages::FetchResponsePartition
- protocol::messages::FetchResponseTopic
- protocol::messages::ListOffsetsRequest
- protocol::messages::ListOffsetsRequestPartition
- protocol::messages::ListOffsetsRequestTopic
- protocol::messages::ListOffsetsResponse
- protocol::messages::ListOffsetsResponsePartition
- protocol::messages::ListOffsetsResponseTopic
- protocol::messages::MetadataRequest
- protocol::messages::MetadataRequestTopic
- protocol::messages::MetadataResponse
- protocol::messages::MetadataResponseBroker
- protocol::messages::MetadataResponsePartition
- protocol::messages::MetadataResponseTopic
- protocol::messages::ProduceRequest
- protocol::messages::ProduceRequestPartitionData
- protocol::messages::ProduceRequestTopicData
- protocol::messages::ProduceResponse
- protocol::messages::ProduceResponsePartitionResponse
- protocol::messages::ProduceResponseResponse
- protocol::messages::RequestHeader
- protocol::messages::ResponseHeader
- protocol::primitives::Array
- protocol::primitives::ArrayRef
- protocol::primitives::Boolean
- protocol::primitives::CompactArray
- protocol::primitives::CompactArrayRef
- protocol::primitives::CompactNullableString
- protocol::primitives::CompactNullableStringRef
- protocol::primitives::CompactString
- protocol::primitives::CompactStringRef
- protocol::primitives::Int16
- protocol::primitives::Int32
- protocol::primitives::Int64
- protocol::primitives::Int8
- protocol::primitives::NullableBytes
- protocol::primitives::NullableString
- protocol::primitives::Records
- protocol::primitives::String_
- protocol::primitives::TaggedFields
- protocol::primitives::UnsignedVarint
- protocol::primitives::Varint
- protocol::primitives::Varlong
- protocol::record::Record
- protocol::record::RecordBatch
- protocol::record::RecordBatchBody
- protocol::record::RecordHeader
- protocol::vec_builder::VecBuilder
- record::Record
- record::RecordAndOffset
- topic::Topic
Enums
- client::ProduceError
- client::consumer::StartOffset
- client::error::Error
- client::error::RequestContext
- client::error::ServerErrorResponse
- client::partition::Compression
- client::partition::OffsetAt
- client::partition::UnknownTopicHandling
- client::producer::Error
- client::producer::aggregator::TryPush
- messenger::RequestError
- messenger::SyncVersionsError
- protocol::api_key::ApiKey
- protocol::error::Error
- protocol::frame::ReadError
- protocol::frame::WriteError
- protocol::messages::IsolationLevel
- protocol::messages::ReadVersionedError
- protocol::messages::WriteVersionedError
- protocol::record::ControlBatchOrRecords
- protocol::record::ControlBatchRecord
- protocol::record::RecordBatchCompression
- protocol::record::RecordBatchTimestampType
- protocol::traits::ReadError
- protocol::traits::WriteError
Traits
- client::producer::ProducerClient
- client::producer::aggregator::Aggregator
- client::producer::aggregator::AggregatorStatus
- client::producer::aggregator::StatusDeaggregator
- protocol::frame::AsyncMessageRead
- protocol::frame::AsyncMessageWrite
- protocol::messages::ReadVersionedType
- protocol::messages::RequestBody
- protocol::messages::WriteVersionedType
- protocol::traits::ReadType
- protocol::traits::WriteType