Struct KafkaProducer

pub struct KafkaProducer {
    inner: FutureProducer,
}

Wrapper around an [rdkafka::producer::FutureProducer].

The producer is configured once and can then be cheaply cloned thanks to the internal Arc in rdkafka’s handle.

Fields

inner: FutureProducer

Implementations

impl KafkaProducer

pub fn new(config: ClientConfig) -> Result<Self>

Explicit configuration.

Arguments

• config - The configuration to use for the producer.
• username - The username to use for authentication
• password - The password to use for authentication

Returns

• Result<Self, SDKError> - The result of the operation

Errors

• SDKError::Producer - If the producer fails to create.

pub fn default( bootstrap_servers: &str, credentials: &ClientCredentials, ) -> Result<Self>

Default configuration.

Arguments

• bootstrap_servers - The bootstrap servers to use for the producer.
• username - The username to use for authentication
• password - The password to use for authentication

Returns

• Result<Self, SDKError> - The result of the operation

Errors

• SDKError::Producer - If the producer fails to create.

pub async fn send_event( &self, topic: &Topic, key: &str, payload: &EventStream, queue_timeout: Option<Duration>, ) -> Result<()>

Sends a key‑ed JSON message to topic.

• payload must be an EventStream object that implements serde::Serialize.
• key is used for partitioning; choose a deterministic key for exactly once‑per‑key semantics.
• queue_timeout is optional; defaults to 5000ms if not provided.

The function is instrumented with [tracing]; any error bubbles up as

Arguments

• topic - The topic to send the message to
• key - The key to send the message to
• payload - The payload to send the message to
• queue_timeout - The timeout to send the message to

Returns

• Result<()> - The result of the operation

Errors

• SDKError::Producer - If the producer fails to send the message.

pub fn serialize_message(&self, msg: &EventStream) -> Result<Vec<u8>>

Serializes an EventStream<T> into a Kafka message.

• T must implement serde::Serialize.

Arguments

• msg - The message to serialize

Returns

• Result<Vec<u8>, SDKError> - The result of the operation

Errors

• SDKError::Producer - If the producer fails to serialize the message.

Trait Implementations

impl Clone for KafkaProducer

fn clone(&self) -> KafkaProducer

Returns a duplicate of the value.

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

Performs copy-assignment from source.