Struct AdminClientConfig 

pub struct AdminClientConfig { /* private fields */ }

Configuration for the admin client.

Corresponds to org.apache.kafka.clients.admin.AdminClientConfig. Unknown keys are accepted silently, matching Java’s AbstractConfig behavior.

Implementations

impl AdminClientConfig

pub const BOOTSTRAP_SERVERS_CONFIG: &'static str = "bootstrap.servers"

bootstrap.servers

pub const BOOTSTRAP_CONTROLLERS_CONFIG: &'static str = "bootstrap.controllers"

bootstrap.controllers (KIP-919). Accepted and validated as in Java, but connecting through controllers is not implemented, so setting it makes Self::new fail (see there).

pub const CLIENT_DNS_LOOKUP_CONFIG: &'static str = CommonClientConfigs::CLIENT_DNS_LOOKUP_CONFIG

Config key: client.dns.lookup. Java’s AdminClientConfig.java declares it as its own public alias of CommonClientConfigs.CLIENT_DNS_LOOKUP_CONFIG.

pub const CLIENT_ID_CONFIG: &'static str = "client.id"

client.id

pub const REQUEST_TIMEOUT_MS_CONFIG: &'static str = "request.timeout.ms"

request.timeout.ms

pub const DEFAULT_API_TIMEOUT_MS_CONFIG: &'static str = "default.api.timeout.ms"

default.api.timeout.ms

pub const RETRIES_CONFIG: &'static str = "retries"

retries

pub const RETRY_BACKOFF_MS_CONFIG: &'static str = "retry.backoff.ms"

retry.backoff.ms

pub const RETRY_BACKOFF_MAX_MS_CONFIG: &'static str = "retry.backoff.max.ms"

retry.backoff.max.ms

pub const RECONNECT_BACKOFF_MS_CONFIG: &'static str = "reconnect.backoff.ms"

reconnect.backoff.ms

pub const RECONNECT_BACKOFF_MAX_MS_CONFIG: &'static str = "reconnect.backoff.max.ms"

reconnect.backoff.max.ms

pub const CONNECTIONS_MAX_IDLE_MS_CONFIG: &'static str = "connections.max.idle.ms"

connections.max.idle.ms

pub const METADATA_MAX_AGE_MS_CONFIG: &'static str = "metadata.max.age.ms"

metadata.max.age.ms

pub const SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG: &'static str = "socket.connection.setup.timeout.ms"

socket.connection.setup.timeout.ms

pub const SECURITY_PROTOCOL_CONFIG: &'static str = CommonClientConfigs::SECURITY_PROTOCOL_CONFIG

security.protocol

pub const SASL_MECHANISM_CONFIG: &'static str = SaslConfigs::SASL_MECHANISM

sasl.mechanism

pub const SASL_JAAS_CONFIG: &'static str = SaslConfigs::SASL_JAAS_CONFIG

sasl.jaas.config

pub fn new(props: &HashMap<String, String>) -> Result<Self, Error>

Creates a config from a property map. bootstrap.servers must be non-empty.

Errors

Returns Error::Config if bootstrap.servers is missing or empty, and an error if a value fails to parse or validate. Following Java’s AdminBootstrapAddresses.fromConfig, setting both bootstrap.servers and bootstrap.controllers is an Error::Config. Setting only bootstrap.controllers returns an UNSUPPORTED_VERSION error (Error::unsupported_version): Java accepts it (KIP-919), but this client does not implement bootstrapping through controllers, and silently ignoring the key would leave the client with no bootstrap address at all.

pub fn bootstrap_servers(&self) -> &[String]

The bootstrap.servers list.

pub fn client_id(&self) -> &str

The client.id.

pub fn request_timeout_ms(&self) -> i32

request.timeout.ms.

pub fn default_api_timeout_ms(&self) -> i32

default.api.timeout.ms.

pub fn retries(&self) -> i32

retries.

pub fn retry_backoff_ms(&self) -> i64

retry.backoff.ms.

pub fn retry_backoff_max_ms(&self) -> i64

retry.backoff.max.ms.

pub fn reconnect_backoff_ms(&self) -> i64

reconnect.backoff.ms.

pub fn reconnect_backoff_max_ms(&self) -> i64

reconnect.backoff.max.ms.

pub fn connections_max_idle_ms(&self) -> i64

connections.max.idle.ms.

pub fn metadata_max_age_ms(&self) -> i64

metadata.max.age.ms.

pub fn socket_connection_setup_timeout_ms(&self) -> i64

socket.connection.setup.timeout.ms.

pub fn security_protocol(&self) -> SecurityProtocol

security.protocol.

pub fn sasl_config(&self) -> &SaslConfigs

SASL configuration (mechanism, JAAS config, credentials).

pub fn ssl_config(&self) -> &SslConfigs

SSL/TLS configuration.

Trait Implementations

impl Clone for AdminClientConfig

fn clone(&self) -> AdminClientConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AdminClientConfig

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

Formats the value using the given formatter.

impl Default for AdminClientConfig

fn default() -> Self

Defaults match AdminClientConfig’s ConfigDef (Apache Kafka 4.2).

impl PartialEq for AdminClientConfig

fn eq(&self, other: &AdminClientConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for AdminClientConfig

impl StructuralPartialEq for AdminClientConfig