Struct KafkaClientBuilder

pub struct KafkaClientBuilder { /* private fields */ }

Helper structure responsible for building the actual KafkaClient.

Implementations

impl KafkaClientBuilder

pub fn new() -> Self

Creates an empty KafkaClientBuilder.

pub fn add_kafka_topic_config( self, topic: KafkaTopic, params: &KafkaParams<'_>, validate_topic: bool, ) -> Result<Self, ClientError>

Adds topic configuration to the current KafkaClientBuilder, which in return assigns dedicates producer to the topic which can will be used to send the messages.

Errors

Returns ClientError::InvalidConfig error if the provided configuration is wrong and the producer could not be created.

pub fn build(self) -> KafkaClient

Consumes self and returns the built KafkaClient.

Trait Implementations

impl Debug for KafkaClientBuilder

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

Formats the value using the given formatter.

impl Default for KafkaClientBuilder

fn default() -> KafkaClientBuilder

Returns the “default value” for a type.