Struct KafkaConnectionConfig 

pub struct KafkaConnectionConfig { /* private fields */ }

Connection configuration for Kafka backend initialization

Implementations

impl KafkaConnectionConfig

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

Create a new connection configuration with required bootstrap servers.

pub fn set_client_id(self, client_id: impl Into<String>) -> Self

Builder-style setter for client id.

pub fn set_timeout_ms(self, timeout_ms: i32) -> Self

Builder-style setter for timeout in milliseconds.

pub fn insert_additional_config<K, V>(self, key: K, value: V) -> Self

where K: Into<String>, V: Into<String>,

Builder-style setter for additional key/value configuration pairs.

pub fn bootstrap_servers(&self) -> &str

pub fn client_id(&self) -> Option<&str>

pub fn timeout_ms(&self) -> i32

pub fn additional_config(&self) -> &HashMap<String, String>

Trait Implementations

impl Clone for KafkaConnectionConfig

fn clone(&self) -> KafkaConnectionConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaConnectionConfig

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

Formats the value using the given formatter.

impl Default for KafkaConnectionConfig

fn default() -> Self

Returns the “default value” for a type.