pub struct KafkaClientConfig {
pub label: String,
pub is_enabled: bool,
pub broker_list: Vec<String>,
pub publish_topics: HashMap<String, String>,
pub num_threads: u8,
pub retry_sleep_sec: u64,
pub idle_sleep_sec: u64,
pub tls_key: String,
pub tls_cert: String,
pub tls_ca: String,
}
Expand description
KafkaClientConfig
Kafka client configuration holding connectivity and static values (tls assets, publishable topics, etc.)
Fields
label: String
is_enabled: bool
broker_list: Vec<String>
publish_topics: HashMap<String, String>
num_threads: u8
retry_sleep_sec: u64
idle_sleep_sec: u64
tls_key: String
tls_cert: String
tls_ca: String
Implementations
Trait Implementations
sourceimpl Clone for KafkaClientConfig
impl Clone for KafkaClientConfig
sourcefn clone(&self) -> KafkaClientConfig
fn clone(&self) -> KafkaClientConfig
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresourceimpl Debug for KafkaClientConfig
impl Debug for KafkaClientConfig
sourceimpl Default for KafkaClientConfig
impl Default for KafkaClientConfig
sourcefn default() -> KafkaClientConfig
fn default() -> KafkaClientConfig
Returns the “default value” for a type. Read more
Auto Trait Implementations
impl RefUnwindSafe for KafkaClientConfig
impl Send for KafkaClientConfig
impl Sync for KafkaClientConfig
impl Unpin for KafkaClientConfig
impl UnwindSafe for KafkaClientConfig
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more