Configuration

yozefu_app::configuration

Trait Configuration 

Source 
pub trait Configuration {
    // Required method
    fn kafka_config_map(&self) -> HashMap<String, String>;

    // Provided methods
    fn create_kafka_consumer<T>(&self) -> Result<T, Error>
       where T: FromClientConfig { ... }
    fn client_config(&self) -> ClientConfig { ... }
    fn kafka_client_config_from_properties(
        kafka_properties: HashMap<String, String>,
    ) -> ClientConfig { ... }
}

Required Methods§

Source

fn kafka_config_map(&self) -> HashMap<String, String>

Returns the kafka properties

Provided Methods§

Source

fn create_kafka_consumer<T>(&self) -> Result<T, Error>
where T: FromClientConfig,

Properties you can set for the kafka consumer: https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md

Source

fn client_config(&self) -> ClientConfig

Properties you can set for the kafka consumer: https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md

Source

fn kafka_client_config_from_properties( kafka_properties: HashMap<String, String>, ) -> ClientConfig

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§