Struct ClusterConfig 

pub struct ClusterConfig {
    pub url_template: Option<String>,
    pub schema_registry: Option<SchemaRegistryConfig>,
    pub kafka: IndexMap<String, String>,
    pub consumer: Option<ConsumerConfig>,
}

Specific configuration for a cluster

Fields

url_template: Option<String>

A placeholder url that will be used when you want to open a kafka record in the browser

schema_registry: Option<SchemaRegistryConfig>

Schema registry configuration

kafka: IndexMap<String, String>

Kafka consumer properties for this cluster, see https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md for more details

consumer: Option<ConsumerConfig>

Implementations

impl ClusterConfig

pub fn normalize_paths(self) -> Self

Normalize all properties that are file locations. For instance, ~/certificates/ca.pem will be resolved to /home/user/certificates/ca.pem.

impl ClusterConfig

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

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

pub fn create(self, cluster: &str) -> YozefuConfig

Trait Implementations

impl Clone for ClusterConfig

fn clone(&self) -> ClusterConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Configuration for ClusterConfig

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 ClusterConfig

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

Formats the value using the given formatter.

impl Default for ClusterConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ClusterConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ClusterConfig

fn eq(&self, other: &ClusterConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ClusterConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for ClusterConfig

impl StructuralPartialEq for ClusterConfig