Struct KafkaClientConfig 

pub struct KafkaClientConfig(/* private fields */);

A wrapper around rdkafka::ClientConfig for convenience.

Provides recommended config with KafkaClientConfig::new_recommended which is configured for at-least-once kafka semantic. Offsets should be manually added to the store. For more info, see the rust-rdkafka/examples/at_least_once.rs example.

Implementations

impl KafkaClientConfig

pub fn new(config: ClientConfig) -> Self

Create a new KafkaClientConfig from an existing rdkafka::ClientConfig.

pub fn new_recommended( group_id: impl Into<String>, brokers: impl Into<String>, ) -> Self

Create a new KafkaClientConfig with a recommended configuration with at-least-once semantics.

Along with group.id and bootstrap.servers, the following config items are set:

• enable.partition.eof=false
• session.timeout.ms=6000
• enable.auto.commit=true
• auto.commit.interval.ms=5000
• enable.auto.offset.store=false

pub fn into_inner(self) -> ClientConfig

Return the inner rdkafka::ClientConfig.

pub fn set<K, V>(&mut self, key: K, value: V) -> &mut Self

where K: Into<String>, V: Into<String>,

Sets a configuration key on the inner rdkafka::ClientConfig.

Trait Implementations

impl AsMut<ClientConfig> for KafkaClientConfig

fn as_mut(&mut self) -> &mut ClientConfig

Converts this type into a mutable reference of the (usually inferred) input type.

impl AsRef<ClientConfig> for KafkaClientConfig

fn as_ref(&self) -> &ClientConfig

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for KafkaClientConfig

fn clone(&self) -> KafkaClientConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaClientConfig

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

Formats the value using the given formatter.

impl From<KafkaClientConfig> for ClientConfig

fn from(config: KafkaClientConfig) -> Self

Converts to this type from the input type.