Struct ClientConfig

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

Available on crate feature kafka only.

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

Creates a new empty configuration.

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

Gets a reference to the underlying config map

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

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>,

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

Removes a parameter from the configuration.

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

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) -> Result<NativeClientConfig, KafkaError>

Builds a native librdkafka configuration.

pub fn create<T>(&self) -> Result<T, KafkaError>

where T: FromClientConfig,

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

pub fn create_with_context<C, T>(&self, context: C) -> Result<T, KafkaError>

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

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

Trait Implementations

impl Clone for ClientConfig

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

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

Formats the value using the given formatter.

impl Default for ClientConfig

fn default() -> ClientConfig

Returns the “default value” for a type.

impl Extend<(String, String)> for ClientConfig

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

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

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

Creates a value from an iterator.