List of all items

Structs

• prelude::BrokerAddress
• prelude::ClusterMetadata
• prelude::ConsumeMessage
• prelude::Consumer
• prelude::ConsumerBuilder
• prelude::ConsumerGroup
• prelude::ConsumerGroupBuilder
• prelude::ProduceMessage
• prelude::Producer
• prelude::ProducerBuilder
• prelude::TcpConnection
• prelude::TlsConnection
• prelude::TlsConnectionOptions
• prelude::TopicPartitionsBuilder
• prelude::encode::AsStrings
• prelude::protocol::Assignment
• prelude::protocol::CreateTopicsRequest
• prelude::protocol::CreateTopicsResponse
• prelude::protocol::DeleteTopicsRequest
• prelude::protocol::DeleteTopicsResponse
• prelude::protocol::FetchRequest
• prelude::protocol::FetchResponse
• prelude::protocol::FindCoordinatorRequest
• prelude::protocol::FindCoordinatorResponse
• prelude::protocol::Header
• prelude::protocol::HeaderRequest
• prelude::protocol::HeaderResponse
• prelude::protocol::HeartbeatRequest
• prelude::protocol::HeartbeatResponse
• prelude::protocol::JoinGroupRequest
• prelude::protocol::JoinGroupResponse
• prelude::protocol::LeaveGroupRequest
• prelude::protocol::LeaveGroupResponse
• prelude::protocol::ListOffsetsRequest
• prelude::protocol::ListOffsetsResponse
• prelude::protocol::MemberAssignment
• prelude::protocol::MetadataRequest
• prelude::protocol::MetadataResponse
• prelude::protocol::OffsetCommitRequest
• prelude::protocol::OffsetCommitResponse
• prelude::protocol::OffsetFetchRequest
• prelude::protocol::OffsetFetchResponse
• prelude::protocol::PartitionAssignment
• prelude::protocol::ProduceRequest
• prelude::protocol::ProduceResponse
• prelude::protocol::SyncGroupRequest
• prelude::protocol::SyncGroupResponse
• prelude::protocol::commit_offset::request::OffsetCommitRequest
• prelude::protocol::commit_offset::request::Partition
• prelude::protocol::commit_offset::request::Topic
• prelude::protocol::commit_offset::response::OffsetCommitResponse
• prelude::protocol::commit_offset::response::Partition
• prelude::protocol::commit_offset::response::Topic
• prelude::protocol::create_topics::request::Assignment
• prelude::protocol::create_topics::request::Config
• prelude::protocol::create_topics::request::CreateTopicsRequest
• prelude::protocol::create_topics::request::Topic
• prelude::protocol::create_topics::response::CreateTopicsResponse
• prelude::protocol::create_topics::response::Topic
• prelude::protocol::delete_topics::request::DeleteTopicsRequest
• prelude::protocol::delete_topics::request::Topic
• prelude::protocol::delete_topics::response::DeleteTopicsResponse
• prelude::protocol::delete_topics::response::Topic
• prelude::protocol::fetch::request::FetchRequest
• prelude::protocol::fetch::request::Partition
• prelude::protocol::fetch::request::TopicPartition
• prelude::protocol::fetch::response::AbortedTransactions
• prelude::protocol::fetch::response::FetchResponse
• prelude::protocol::fetch::response::Header
• prelude::protocol::fetch::response::Partition
• prelude::protocol::fetch::response::Record
• prelude::protocol::fetch::response::RecordBatch
• prelude::protocol::fetch::response::Topic
• prelude::protocol::fetch::response_optimized::AbortedTransactions
• prelude::protocol::fetch::response_optimized::FetchResponse
• prelude::protocol::fetch::response_optimized::Header
• prelude::protocol::fetch::response_optimized::Partition
• prelude::protocol::fetch::response_optimized::Record
• prelude::protocol::fetch::response_optimized::RecordBatch
• prelude::protocol::fetch::response_optimized::Topic
• prelude::protocol::find_coordinator::request::FindCoordinatorRequest
• prelude::protocol::find_coordinator::response::FindCoordinatorResponse
• prelude::protocol::heartbeat::request::HeartbeatRequest
• prelude::protocol::heartbeat::response::HeartbeatResponse
• prelude::protocol::join_group::request::JoinGroupRequest
• prelude::protocol::join_group::request::Metadata
• prelude::protocol::join_group::request::Protocol
• prelude::protocol::join_group::response::JoinGroupResponse
• prelude::protocol::join_group::response::Member
• prelude::protocol::leave_group::request::LeaveGroupRequest
• prelude::protocol::leave_group::response::LeaveGroupResponse
• prelude::protocol::list_offsets::request::ListOffsetsRequest
• prelude::protocol::list_offsets::request::Partition
• prelude::protocol::list_offsets::request::Topic
• prelude::protocol::list_offsets::response::ListOffsetsResponse
• prelude::protocol::list_offsets::response::Partition
• prelude::protocol::list_offsets::response::Topic
• prelude::protocol::metadata::request::MetadataRequest
• prelude::protocol::metadata::response::Broker
• prelude::protocol::metadata::response::MetadataResponse
• prelude::protocol::metadata::response::Partition
• prelude::protocol::metadata::response::Topic
• prelude::protocol::offset_fetch::request::OffsetFetchRequest
• prelude::protocol::offset_fetch::request::Topic
• prelude::protocol::offset_fetch::response::OffsetFetchResponse
• prelude::protocol::offset_fetch::response::Partition
• prelude::protocol::offset_fetch::response::Topic
• prelude::protocol::produce::request::Attributes
• prelude::protocol::produce::request::Header
• prelude::protocol::produce::request::Message
• prelude::protocol::produce::request::ProduceRequest
• prelude::protocol::produce::request::Record
• prelude::protocol::produce::request::RecordBatch
• prelude::protocol::produce::response::PartitionResponse
• prelude::protocol::produce::response::ProduceResponse
• prelude::protocol::produce::response::Response
• prelude::protocol::sync_group::request::Assignment
• prelude::protocol::sync_group::request::MemberAssignment
• prelude::protocol::sync_group::request::PartitionAssignment
• prelude::protocol::sync_group::request::SyncGroupRequest
• prelude::protocol::sync_group::response::MemberAssignment
• prelude::protocol::sync_group::response::PartitionAssignment
• prelude::protocol::sync_group::response::SyncGroupResponse

Enums

• prelude::Compression
• prelude::Error
• prelude::KafkaCode

Traits

• prelude::BrokerConnection
• prelude::encode::ToByte

Functions

• prelude::commit_offset
• prelude::create_topics
• prelude::delete_topics
• prelude::encode::encode_as_array
• prelude::fetch
• prelude::fetch_offset
• prelude::find_coordinator
• prelude::heartbeat
• prelude::join_group
• prelude::leave_group
• prelude::list_offsets
• prelude::produce
• prelude::protocol::commit_offset::response::parse_offset_commit_response
• prelude::protocol::create_topics::response::parse_create_topics_response
• prelude::protocol::delete_topics::response::parse_delete_topics_response
• prelude::protocol::fetch::response::parse_fetch_response
• prelude::protocol::fetch::response::parse_record_batch
• prelude::protocol::fetch::response_optimized::parse_fetch_response
• prelude::protocol::find_coordinator::response::parse_find_coordinator_response
• prelude::protocol::heartbeat::response::parse_heartbeat_response
• prelude::protocol::join_group::response::parse_join_group_response
• prelude::protocol::leave_group::response::parse_leave_group_response
• prelude::protocol::list_offsets::response::parse_list_offsets_response
• prelude::protocol::metadata::response::parse_metadata_response
• prelude::protocol::offset_fetch::response::parse_offset_fetch_response
• prelude::protocol::parse_header_response
• prelude::protocol::produce::response::parse_partition_response
• prelude::protocol::produce::response::parse_produce_fetch_response
• prelude::protocol::produce::response::parse_response
• prelude::protocol::sync_group::response::parse_sync_group_response
• prelude::sync_group

Type Aliases

• prelude::PartitionOffsets
• prelude::Result
• prelude::TopicPartitions

Constants

• prelude::ROUND_ROBIN_PROTOCOL
• prelude::encode::MSB