Struct sea_streamer_kafka::KafkaConnectOptions
source ยท pub struct KafkaConnectOptions { /* private fields */ }
Implementationsยง
sourceยงimpl KafkaConnectOptions
impl KafkaConnectOptions
sourcepub fn set_security_protocol(&mut self, v: SecurityProtocol) -> &mut Self
pub fn set_security_protocol(&mut self, v: SecurityProtocol) -> &mut Self
Set the security protocol
pub fn security_protocol(&self) -> Option<&SecurityProtocol>
sourcepub fn set_sasl_options(&mut self, v: SaslOptions) -> &mut Self
pub fn set_sasl_options(&mut self, v: SaslOptions) -> &mut Self
Set the SASL options
pub fn sasl_options(&self) -> Option<&SaslOptions>
sourcepub fn add_custom_option<K, V>(&mut self, key: K, value: V) -> &mut Selfwhere
K: Into<String>,
V: Into<String>,
pub fn add_custom_option<K, V>(&mut self, key: K, value: V) -> &mut Selfwhere 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ยง
sourceยงimpl Clone for KafkaConnectOptions
impl Clone for KafkaConnectOptions
sourceยงfn clone(&self) -> KafkaConnectOptions
fn clone(&self) -> KafkaConnectOptions
Returns a copy of the value. Read more
1.0.0 ยท sourceยงfn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresourceยงimpl ConnectOptions for KafkaConnectOptions
impl ConnectOptions for KafkaConnectOptions
sourceยงfn set_timeout(&mut self, v: Duration) -> KafkaResult<&mut Self>
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>
sourceยงimpl Debug for KafkaConnectOptions
impl Debug for KafkaConnectOptions
sourceยงimpl Default for KafkaConnectOptions
impl Default for KafkaConnectOptions
sourceยงfn default() -> KafkaConnectOptions
fn default() -> KafkaConnectOptions
Returns the โdefault valueโ for a type. Read more
Auto Trait Implementationsยง
impl RefUnwindSafe for KafkaConnectOptions
impl Send for KafkaConnectOptions
impl Sync for KafkaConnectOptions
impl Unpin for KafkaConnectOptions
impl UnwindSafe for KafkaConnectOptions
Blanket Implementationsยง
sourceยงimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
sourceยงfn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more