Struct YozefuConfig 

pub struct YozefuConfig {
    pub log_file: Option<PathBuf>,
    pub export_directory: Option<PathBuf>,
    /* private fields */
}

composed of kafka properties and an optional user-specific configuration.

Fields

log_file: Option<PathBuf>

export_directory: Option<PathBuf>

Implementations

impl YozefuConfig

pub fn cluster(&self) -> &str

pub fn url_template(&self) -> Option<String>

pub fn config(&self) -> &ClusterConfig

pub fn schema_registry(&self) -> Option<SchemaRegistryConfig>

pub fn with_exported_directory(self, exported_directory: PathBuf) -> Self

pub fn with_logs_file(self, logs_file: PathBuf) -> Self

pub fn set_kafka_property(&mut self, key: &str, value: &str)

pub fn update_kafka_properties( self, kafka_properties: HashMap<String, String>, ) -> Self

Overrides the kafka properties with the properties provided by the user

Trait Implementations

impl Clone for YozefuConfig

fn clone(&self) -> YozefuConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Configuration for YozefuConfig

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

Returns the kafka properties

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

fn client_config(&self) -> ClientConfig

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

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

impl Debug for YozefuConfig

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

Formats the value using the given formatter.