Struct Config 

pub struct Config {

    pub bootstrap_servers: String,
    pub writer_request_max_size: i32,
    pub writer_acks: String,
    pub writer_retries: i32,
    pub writer_batch_size: i32,
    pub writer_bucket_no_key_assigner: NoKeyAssigner,
    pub scanner_remote_log_prefetch_num: usize,
    pub remote_file_download_thread_num: usize,
    pub scanner_remote_log_read_concurrency: usize,
    pub scanner_log_max_poll_records: usize,
    pub scanner_log_fetch_max_bytes: i32,
    pub scanner_log_fetch_min_bytes: i32,
    pub scanner_log_fetch_wait_max_time_ms: i32,
    pub writer_batch_timeout_ms: i64,
    pub scanner_log_fetch_max_bytes_for_bucket: i32,
    pub writer_enable_idempotence: bool,
    pub writer_max_inflight_requests_per_bucket: usize,
    pub writer_buffer_memory_size: usize,
    pub writer_buffer_wait_timeout_ms: u64,
    pub connect_timeout_ms: u64,
    pub security_protocol: String,
    pub security_sasl_mechanism: String,
    pub security_sasl_username: String,
    pub security_sasl_password: String,
}

Fields

bootstrap_servers: String

writer_request_max_size: i32

writer_acks: String

writer_retries: i32

writer_batch_size: i32

writer_bucket_no_key_assigner: NoKeyAssigner

scanner_remote_log_prefetch_num: usize

Maximum number of remote log segments to prefetch Default: 4 (matching Java CLIENT_SCANNER_REMOTE_LOG_PREFETCH_NUM)

remote_file_download_thread_num: usize

Maximum concurrent remote log downloads Default: 3 (matching Java REMOTE_FILE_DOWNLOAD_THREAD_NUM)

scanner_remote_log_read_concurrency: usize

Intra-file remote log read concurrency for each remote segment download. Download path always uses streaming reader.

scanner_log_max_poll_records: usize

Maximum number of records returned in a single call to poll() for LogScanner. Default: 500 (matching Java CLIENT_SCANNER_LOG_MAX_POLL_RECORDS)

scanner_log_fetch_max_bytes: i32

Maximum bytes per fetch response for LogScanner. Default: 16777216 (16MB)

scanner_log_fetch_min_bytes: i32

Minimum bytes to accumulate before returning a fetch response. Default: 1

scanner_log_fetch_wait_max_time_ms: i32

Maximum time the server may wait (ms) to satisfy min-bytes. Default: 500

writer_batch_timeout_ms: i64

The maximum time to wait for a batch to be completed in milliseconds. Default: 100 (matching Java CLIENT_WRITER_BATCH_TIMEOUT)

scanner_log_fetch_max_bytes_for_bucket: i32

Maximum bytes per fetch response per bucket for LogScanner. Default: 1048576 (1MB)

writer_enable_idempotence: bool

Whether to enable idempotent writes. When enabled, each batch is tagged with a server-allocated writer ID and per-bucket sequence number so the server can detect and deduplicate retried batches. Default: true (matching Java CLIENT_WRITER_ENABLE_IDEMPOTENCE)

writer_max_inflight_requests_per_bucket: usize

Maximum number of in-flight requests per bucket for idempotent writes. Default: 5 (matching Java client.writer.max-inflight-requests-per-bucket)

writer_buffer_memory_size: usize

Total memory available for buffering write batches across all buckets. When this limit is reached, upsert()/append() will block until in-flight batches complete and free memory. Default: 64MB (matching Java’s LazyMemorySegmentPool: 512 pages x 128KB)

writer_buffer_wait_timeout_ms: u64

Maximum time in milliseconds to block waiting for buffer memory. If the timeout is exceeded, the write call returns an error.

connect_timeout_ms: u64

Connect timeout in milliseconds for TCP transport connect. Default: 120000 (120 seconds).

security_protocol: String

security_sasl_mechanism: String

security_sasl_username: String

security_sasl_password: String

Implementations

impl Config

pub fn is_sasl_enabled(&self) -> bool

Returns true when the security protocol indicates SASL authentication should be performed. Matches Java’s SaslAuthenticationPlugin which registers as "sasl" (case-insensitive).

pub fn validate_idempotence(&self) -> Result<(), String>

Validates idempotence configuration. Returns Ok(()) when the config is consistent, or an error message when idempotence is enabled but other settings are incompatible.

pub fn validate_security(&self) -> Result<(), String>

Validates security configuration. Returns Ok(()) when the config is consistent, or an error message when SASL is enabled but the config is incomplete or uses an unsupported mechanism.

pub fn validate_scanner_fetch(&self) -> Result<(), String>

Trait Implementations

impl Args for Config

fn group_id() -> Option<Id>

Report the ArgGroup::id for this set of arguments

fn augment_args<'b>(__clap_app: Command) -> Command

Append to Command so it can instantiate Self via FromArgMatches::from_arg_matches_mut

fn augment_args_for_update<'b>(__clap_app: Command) -> Command

Append to Command so it can instantiate self via FromArgMatches::update_from_arg_matches_mut

impl Clone for Config

fn clone(&self) -> Config

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CommandFactory for Config

fn command<'b>() -> Command

Build a Command that can instantiate Self.

fn command_for_update<'b>() -> Command

Build a Command that can update self.

impl Debug for Config

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

Formats the value using the given formatter.

impl Default for Config

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Config

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl FromArgMatches for Config

fn from_arg_matches(__clap_arg_matches: &ArgMatches) -> Result<Self, Error>

Instantiate Self from ArgMatches, parsing the arguments as needed.

fn from_arg_matches_mut( __clap_arg_matches: &mut ArgMatches, ) -> Result<Self, Error>

Instantiate Self from ArgMatches, parsing the arguments as needed.

fn update_from_arg_matches( &mut self, __clap_arg_matches: &ArgMatches, ) -> Result<(), Error>

Assign values from ArgMatches to self.

fn update_from_arg_matches_mut( &mut self, __clap_arg_matches: &mut ArgMatches, ) -> Result<(), Error>

Assign values from ArgMatches to self.

impl Parser for Config

fn parse() -> Self

Parse from std::env::args_os(), exit on error.

fn try_parse() -> Result<Self, Error>

Parse from std::env::args_os(), return Err on error.

fn parse_from<I, T>(itr: I) -> Self

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Parse from iterator, exit on error.

fn try_parse_from<I, T>(itr: I) -> Result<Self, Error>

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Parse from iterator, return Err on error.

fn update_from<I, T>(&mut self, itr: I)

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Update from iterator, exit on error.

fn try_update_from<I, T>(&mut self, itr: I) -> Result<(), Error>

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Update from iterator, return Err on error.

impl Serialize for Config

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.