Struct KafkaConfig

pub struct KafkaConfig {
    pub bootstrap_servers: String,
    pub topic: String,
    pub group_id: String,
    pub auto_offset_reset: String,
    pub session_timeout_ms: u64,
}

Configuration for Kafka source

Fields

bootstrap_servers: String

Bootstrap servers (comma-separated list)

topic: String

Topic to consume from

group_id: String

Consumer group ID

auto_offset_reset: String

Auto offset reset (earliest/latest)

session_timeout_ms: u64

Session timeout (in milliseconds)

Trait Implementations

impl Clone for KafkaConfig

fn clone(&self) -> KafkaConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaConfig

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

Formats the value using the given formatter.

impl Default for KafkaConfig

fn default() -> Self

Returns the “default value” for a type.