List of all items

Structs

• client::BrokerAddr
• client::BrokerRewrite
• client::MzClientContext
• client::TimeoutConfig
• client::TunnelingClientContext

Enums

• admin::CreateTopicError
• admin::DeleteTopicError
• aws::SignerError
• client::BrokerRewriteHandle
• client::GetPartitionsError
• client::MzKafkaError
• client::TunnelConfig

Functions

• admin::create_new_topic
• admin::create_topic_helper
• admin::delete_existing_topic
• admin::delete_topic
• admin::delete_topic_helper
• admin::ensure_topic
• aws::base64_encode
• aws::build_url
• aws::generate_auth_token
• aws::get_expiration_time_ms
• aws::sign_url
• client::create_new_client_config
• client::create_new_client_config_simple
• client::get_partitions

Type Aliases

• client::PartitionId

Constants

• aws::DEFAULT_EXPIRY_SECONDS
• client::DEFAULT_FETCH_METADATA_TIMEOUT
• client::DEFAULT_KEEPALIVE
• client::DEFAULT_METADATA_FETCH_INTERVAL
• client::DEFAULT_PROGRESS_RECORD_FETCH_TIMEOUT
• client::DEFAULT_SOCKET_CONNECTION_SETUP_TIMEOUT
• client::DEFAULT_SOCKET_TIMEOUT
• client::DEFAULT_TOPIC_METADATA_REFRESH_INTERVAL
• client::DEFAULT_TRANSACTION_TIMEOUT