Struct AdminConfig 

pub struct AdminConfig {
    pub bootstrap_servers: Vec<String>,
    pub client_id: String,
    pub security_protocol: SecurityProtocol,
    pub tls: TlsConfig,
    pub sasl: SaslConfig,
    pub request_timeout: Duration,
    pub tcp_connector: Arc<dyn TcpConnector>,
}

Admin Config.

Fields

bootstrap_servers: Vec<String>

Bootstrap Servers.

client_id: String

Client Id.

security_protocol: SecurityProtocol

Security Protocol.

tls: TlsConfig

Tls.

sasl: SaslConfig

Sasl.

request_timeout: Duration

Request Timeout.

tcp_connector: Arc<dyn TcpConnector>

TCP connector.

Implementations

impl AdminConfig

pub fn new(bootstrap_server: impl Into<String>) -> Self

Creates a new value.

pub fn with_client_id(self, client_id: impl Into<String>) -> Self

Sets client id and returns the updated value.

pub fn with_bootstrap_servers( self, servers: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Sets bootstrap servers and returns the updated value.

pub fn with_security_protocol(self, security_protocol: SecurityProtocol) -> Self

Sets security protocol and returns the updated value.

pub fn with_tls(self, tls: TlsConfig) -> Self

Sets tls and returns the updated value.

pub fn with_tls_ca_cert_path(self, path: impl Into<PathBuf>) -> Self

Sets tls ca cert path and returns the updated value.

pub fn with_tls_client_auth_paths( self, cert_path: impl Into<PathBuf>, key_path: impl Into<PathBuf>, ) -> Self

Sets tls client auth paths and returns the updated value.

pub fn with_tls_server_name(self, server_name: impl Into<String>) -> Self

Sets tls server name and returns the updated value.

pub fn with_sasl(self, sasl: SaslConfig) -> Self

Sets sasl and returns the updated value.

pub fn with_sasl_plain( self, username: impl Into<String>, password: impl Into<String>, ) -> Self

Sets sasl plain and returns the updated value.

pub fn with_sasl_scram_sha_256( self, username: impl Into<String>, password: impl Into<String>, ) -> Self

Sets sasl scram sha 256 and returns the updated value.

pub fn with_sasl_scram_sha_512( self, username: impl Into<String>, password: impl Into<String>, ) -> Self

Sets sasl scram sha 512 and returns the updated value.

pub fn with_request_timeout(self, request_timeout: Duration) -> Self

Sets request timeout and returns the updated value.

pub fn with_tcp_connector(self, tcp_connector: Arc<dyn TcpConnector>) -> Self

Sets TCP connector and returns the updated value.

Trait Implementations

impl Clone for AdminConfig

fn clone(&self) -> AdminConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AdminConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.