Struct rdkafka::config::ClientConfig

pub struct ClientConfig {
    pub log_level: RDKafkaLogLevel,
    // some fields omitted
}

Client configuration.

Fields

log_level: RDKafkaLogLevel

Methods

impl ClientConfig

pub fn new() -> ClientConfig

Creates a new empty configuration.

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

Sets a new parameter in 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) -> KafkaResult<NativeClientConfig>

Returns the native rdkafka-sys configuration.

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

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

pub fn create_with_context<C, T>(&self, context: C) -> KafkaResult<T> 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 copy of the value.

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

Performs copy-assignment from source.

impl Default for ClientConfig

fn default() -> Self

Returns the "default value" for a type.