Struct KafkaSinkConfig 

pub struct KafkaSinkConfig {

    pub brokers: String,
    pub topic: String,
    pub client_id: String,
    pub batch_size: usize,
    pub send_timeout_ms: u64,
    pub enable_idempotence: bool,
    pub enable_transactions: bool,
    pub transactional_id: Option<String>,
    pub compression_type: String,
    pub acks: String,
    pub max_retries: u32,
    pub base_backoff_ms: u64,
    pub max_in_flight_requests: usize,
    pub linger_ms: u64,
    pub buffer_memory: usize,
    pub enable_circuit_breaker: bool,
    pub circuit_breaker_threshold: u32,
    pub circuit_breaker_timeout_secs: u64,
}

Configuration for Kafka sink

Fields

brokers: String

Kafka bootstrap servers

topic: String

Default topic for messages

client_id: String

Client ID for this producer

batch_size: usize

Batch size for batching messages

send_timeout_ms: u64

Timeout for sending messages (milliseconds)

enable_idempotence: bool

Enable idempotent producer

enable_transactions: bool

Enable transactions for exactly-once semantics

transactional_id: Option<String>

Transaction ID (required if transactions enabled)

compression_type: String

Compression type (none, gzip, snappy, lz4, zstd)

acks: String

Acknowledgment level (0, 1, all)

max_retries: u32

Maximum retries for failed sends

base_backoff_ms: u64

Base delay for exponential backoff (milliseconds)

max_in_flight_requests: usize

Maximum in-flight requests

linger_ms: u64

Linger time for batching (milliseconds)

buffer_memory: usize

Buffer memory size (bytes)

enable_circuit_breaker: bool

Enable circuit breaker

circuit_breaker_threshold: u32

Circuit breaker failure threshold

circuit_breaker_timeout_secs: u64

Circuit breaker timeout (seconds)

Trait Implementations

impl Clone for KafkaSinkConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaSinkConfig

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

Formats the value using the given formatter.

impl Default for KafkaSinkConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for KafkaSinkConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for KafkaSinkConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.