Struct KafkaConfig 

pub struct KafkaConfig { /* private fields */ }

Raw Kafka property map with typed helpers for common Datum defaults.

Implementations

impl KafkaConfig

pub fn new(bootstrap_servers: impl Into<String>) -> Self

pub fn empty() -> Self

pub fn get(&self, key: &str) -> Option<&str>

pub fn properties(&self) -> &BTreeMap<String, String>

pub fn set( &mut self, key: impl Into<String>, value: impl Into<String>, ) -> &mut Self

pub fn with(self, key: impl Into<String>, value: impl Into<String>) -> Self

pub fn with_tls( self, ca_location: impl Into<String>, certificate_location: impl Into<String>, key_location: impl Into<String>, ) -> Self

Sets the common TLS properties understood by both backends.

pub fn with_sasl_plain( self, username: impl Into<String>, password: impl Into<String>, ) -> Self

Sets SASL/SSL PLAIN properties.

This is a property helper only. The selected backend must support the requested SASL mechanism.

Trait Implementations

impl Clone for KafkaConfig

fn clone(&self) -> KafkaConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaConfig

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

Formats the value using the given formatter.

impl Eq for KafkaConfig

impl PartialEq for KafkaConfig

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for KafkaConfig