Struct ClientConfig 

pub struct ClientConfig {
    pub log_level: RDKafkaLogLevel,
    /* private fields */
}

Client configuration.

Fields

log_level: RDKafkaLogLevel

The librdkafka logging level. Refer to RDKafkaLogLevel for the list of available levels.

Implementations

impl ClientConfig

pub fn new() -> ClientConfig

Available on non-madsim only.

Creates a new empty configuration.

pub fn config_map(&self) -> &HashMap<String, String>

Available on non-madsim only.

Gets a reference to the underlying config map

pub fn get(&self, key: &str) -> Option<&str>

Available on non-madsim only.

Gets the value of a parameter in the configuration.

Returns the current value set for key, or None if no value for key exists.

Note that this method will only ever return values that were installed by a call to ClientConfig::set. To retrieve librdkafka’s default value for a parameter, build a NativeClientConfig and then call NativeClientConfig::get on the resulting object.

pub fn set<K, V>(&mut self, key: K, value: V) -> &mut ClientConfig

where K: Into<String>, V: Into<String>,

Available on non-madsim only.

Sets a parameter in the configuration.

If there is an existing value for key in the configuration, it is overridden with the new value.

pub fn remove<'a>(&'a mut self, key: &str) -> &'a mut ClientConfig

Available on non-madsim only.

Removes a parameter from the configuration.

pub fn set_log_level(&mut self, log_level: RDKafkaLogLevel) -> &mut ClientConfig

Available on non-madsim only.

Sets the log level of the client. If not specified, the log level will be calculated based on the global log level of the log crate.

pub fn create_native_config(&self) -> KafkaResult<NativeClientConfig>

Available on non-madsim only.

Builds a native librdkafka configuration.

pub async fn create<T: FromClientConfig>(&self) -> KafkaResult<T>

Available on non-madsim only.

Uses the current configuration to create a new Consumer or Producer.

pub async fn create_with_context<C, T>(&self, context: C) -> KafkaResult<T>

where C: ClientContext, T: FromClientConfigAndContext<C>,

Available on non-madsim only.

Uses the current configuration and the provided context to create a new Consumer or Producer.

Trait Implementations

impl Clone for ClientConfig

Available on non-madsim only.

fn clone(&self) -> ClientConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClientConfig

Available on non-madsim only.

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

Formats the value using the given formatter.

impl Default for ClientConfig

Available on non-madsim only.

fn default() -> Self

Returns the “default value” for a type.

impl Extend<(String, String)> for ClientConfig

Available on non-madsim only.

fn extend<I>(&mut self, iter: I)

where I: IntoIterator<Item = (String, String)>,

Extends a collection with the contents of an iterator.

fn extend_one(&mut self, item: A)

🔬This is a nightly-only experimental API. (extend_one)

Extends a collection with exactly one element.

fn extend_reserve(&mut self, additional: usize)

🔬This is a nightly-only experimental API. (extend_one)

Reserves capacity in a collection for the given number of additional elements.

impl FromIterator<(String, String)> for ClientConfig

Available on non-madsim only.

fn from_iter<I>(iter: I) -> ClientConfig

where I: IntoIterator<Item = (String, String)>,

Creates a value from an iterator.