List of all items

Structs

• admin::AdminClient
• admin::AdminOptions
• admin::AlterConfig
• admin::ConfigEntry
• admin::ConfigResource
• admin::NewPartitions
• admin::NewTopic
• client::Client
• client::DefaultClientContext
• client::NativeClient
• config::ClientConfig
• config::NativeClientConfig
• consumer::BaseConsumer
• consumer::ConsumerGroupMetadata
• consumer::DefaultConsumerContext
• consumer::MessageStream
• consumer::StreamConsumer
• consumer::base_consumer::BaseConsumer
• consumer::base_consumer::Iter
• consumer::base_consumer::PartitionQueue
• consumer::stream_consumer::MessageStream
• consumer::stream_consumer::StreamConsumer
• consumer::stream_consumer::StreamPartitionQueue
• error::RDKafkaError
• groups::GroupInfo
• groups::GroupList
• groups::GroupMemberInfo
• message::BorrowedHeaders
• message::BorrowedMessage
• message::OwnedHeaders
• message::OwnedMessage
• metadata::Metadata
• metadata::MetadataBroker
• metadata::MetadataPartition
• metadata::MetadataTopic
• producer::BaseProducer
• producer::BaseRecord
• producer::DefaultProducerContext
• producer::DeliveryFuture
• producer::FutureProducer
• producer::FutureRecord
• producer::ThreadedProducer
• producer::base_producer::BaseProducer
• producer::base_producer::BaseRecord
• producer::base_producer::ThreadedProducer
• producer::future_producer::DeliveryFuture
• producer::future_producer::FutureProducer
• producer::future_producer::FutureProducerContext
• producer::future_producer::FutureRecord
• statistics::Broker
• statistics::ConsumerGroup
• statistics::ExactlyOnceSemantics
• statistics::Partition
• statistics::Statistics
• statistics::Topic
• statistics::TopicPartition
• statistics::Window
• topic_partition_list::TopicPartitionList
• topic_partition_list::TopicPartitionListElem
• util::NaiveRuntime
• util::TokioRuntime

Enums

• admin::ConfigSource
• admin::OwnedResourceSpecifier
• admin::ResourceSpecifier
• admin::TopicReplication
• config::RDKafkaLogLevel
• consumer::CommitMode
• consumer::Rebalance
• consumer::RebalanceProtocol
• error::KafkaError
• error::RDKafkaErrorCode
• message::Timestamp
• topic_partition_list::Offset
• types::RDKafkaAdminOp
• types::RDKafkaConfRes
• types::RDKafkaConfigSource
• types::RDKafkaErrorCode
• types::RDKafkaResourceType
• types::RDKafkaRespErr
• types::RDKafkaType
• util::Timeout

Traits

• client::ClientContext
• config::FromClientConfig
• config::FromClientConfigAndContext
• consumer::Consumer
• consumer::ConsumerContext
• error::IsError
• message::FromBytes
• message::Headers
• message::Message
• message::ToBytes
• producer::Producer
• producer::ProducerContext
• util::AsyncRuntime
• util::IntoOpaque

Functions

• util::cstr_to_owned
• util::current_time_millis
• util::get_rdkafka_version
• util::millis_to_epoch

Typedefs

• admin::AlterConfigsResult
• admin::ConfigResourceResult
• admin::PartitionAssignment
• admin::TopicResult
• error::KafkaResult
• message::DeliveryResult
• producer::DeliveryResult
• producer::future_producer::OwnedDeliveryResult
• types::RDKafka
• types::RDKafkaAdminOptions
• types::RDKafkaConf
• types::RDKafkaConfigResource
• types::RDKafkaConsumerGroupMetadata
• types::RDKafkaDeleteTopic
• types::RDKafkaEvent
• types::RDKafkaGroupInfo
• types::RDKafkaGroupList
• types::RDKafkaGroupMemberInfo
• types::RDKafkaHeaders
• types::RDKafkaMessage
• types::RDKafkaMetadata
• types::RDKafkaMetadataBroker
• types::RDKafkaMetadataPartition
• types::RDKafkaMetadataTopic
• types::RDKafkaNewPartitions
• types::RDKafkaNewTopic
• types::RDKafkaQueue
• types::RDKafkaState
• types::RDKafkaTopic
• types::RDKafkaTopicConf
• types::RDKafkaTopicPartition
• types::RDKafkaTopicPartitionList
• types::RDKafkaTopicResult
• util::DefaultRuntime