Struct KafkaSourceConfigBuilder 

pub struct KafkaSourceConfigBuilder { /* private fields */ }

Builder for KafkaSourceConfig.

Implementations

impl KafkaSourceConfigBuilder

pub fn bootstrap_servers(self, servers: Vec<String>) -> Self

pub fn group_id(self, group_id: String) -> Self

pub fn topics(self, topics: Vec<String>) -> Self

pub fn auto_offset_reset(self, reset: String) -> Self

pub fn enable_auto_commit(self, enable: bool) -> Self

pub fn auto_commit_interval(self, interval: Duration) -> Self

pub fn max_poll_records(self, records: usize) -> Self

pub fn fetch_wait_max(self, duration: Duration) -> Self

pub fn fetch_min_bytes(self, bytes: usize) -> Self

pub fn max_partition_fetch_bytes(self, bytes: usize) -> Self

pub fn session_timeout(self, timeout: Duration) -> Self

pub fn heartbeat_interval(self, interval: Duration) -> Self

pub fn security_protocol(self, protocol: SecurityProtocol) -> Self

pub fn sasl_mechanism(self, mechanism: SaslMechanism) -> Self

pub fn sasl_username(self, username: String) -> Self

pub fn sasl_password(self, password: String) -> Self

pub fn ssl_config(self, config: SslConfig) -> Self

pub fn num_consumer_threads(self, threads: usize) -> Self

pub fn queued_max_messages(self, messages: usize) -> Self

pub fn socket_receive_buffer_bytes(self, bytes: usize) -> Self

pub fn isolation_level(self, level: String) -> Self

pub fn additional_properties(self, properties: HashMap<String, String>) -> Self

pub fn build(self) -> Result<KafkaSourceConfig, String>

Trait Implementations

impl Default for KafkaSourceConfigBuilder

fn default() -> Self

Returns the “default value” for a type.