Struct sea_streamer_kafka::KafkaConnectOptions

pub struct KafkaConnectOptions { /* private fields */ }

Implementations

impl KafkaConnectOptions

pub fn set_security_protocol(&mut self, v: SecurityProtocol) -> &mut Self

Set the security protocol

pub fn security_protocol(&self) -> Option<&SecurityProtocol>

pub fn set_sasl_options(&mut self, v: SaslOptions) -> &mut Self

Set the SASL options

pub fn sasl_options(&self) -> Option<&SaslOptions>

pub fn add_custom_option<K, V>(&mut self, key: K, value: V) -> &mut Self

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

Add a custom option. If you have an option you frequently use, please consider open a PR and add it to above.

pub fn custom_options(&self) -> impl Iterator<Item = (&str, &str)>

Trait Implementations

impl Clone for KafkaConnectOptions

fn clone(&self) -> KafkaConnectOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ConnectOptions for KafkaConnectOptions

fn set_timeout(&mut self, v: Duration) -> KafkaResult<&mut Self>

Timeout for network requests. Default is 1 min

type Error = KafkaError

fn timeout(&self) -> KafkaResult<Duration>

impl Debug for KafkaConnectOptions

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

Formats the value using the given formatter.

impl Default for KafkaConnectOptions

fn default() -> KafkaConnectOptions

Returns the “default value” for a type.