Struct rdkafka::config::ClientConfig

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

Client configuration.

Fields

log_level: RDKafkaLogLevel

Methods

impl ClientConfig

fn new() -> ClientConfig

Creates a new empty configuration.

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

Sets a new parameter in the configuration.

fn set_default_topic_config(&mut self,
                            default_topic_config: TopicConfig)
                            -> &mut ClientConfig

Sets the default topic configuration to use for automatically subscribed topics (e.g., through pattern-matched topics).

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.

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

Returns the native rdkafka-sys configuration.

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

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

fn create_with_context<C, T>(&self, context: C) -> KafkaResult<T> where C: Context, 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.