Struct KafkaConfig 

pub struct KafkaConfig {
    pub brokers: String,
    pub default_topic: String,
    pub client_id: String,
    pub acks: String,
    pub timeout_ms: u64,
    pub compression: Option<String>,
}

Kafka transport adapter configuration.

Fields

brokers: String

Kafka broker addresses (comma-separated).

default_topic: String

Default topic for events (can be overridden per subscription).

client_id: String

Client ID for Kafka producer.

acks: String

Message acknowledgment mode (“all”, “1”, “0”).

timeout_ms: u64

Message timeout in milliseconds.

compression: Option<String>

Enable message compression.

Implementations

impl KafkaConfig

pub fn new(brokers: impl Into<String>, default_topic: impl Into<String>) -> Self

Create a new Kafka configuration.

pub fn with_client_id(self, client_id: impl Into<String>) -> Self

Set the client ID.

pub fn with_acks(self, acks: impl Into<String>) -> Self

Set acknowledgment mode.

pub fn with_timeout(self, timeout_ms: u64) -> Self

Set message timeout.

pub fn with_compression(self, compression: impl Into<String>) -> Self

Enable compression (e.g., “gzip”, “snappy”, “lz4”).

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.