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 Kafka client builder.

pub fn add_kafka_topic_config( self, topic: KafkaTopic, topic_config: &KafkaTopicConfig<'_>, validate_topic: bool, source: &KafkaConfigSource<'_>, ) -> 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.

Each physical topic’s client is resolved from the config blob in source, and is replaced whenever a newer blob is pushed in through KafkaClient::push_kafka_config.

Errors

Returns ClientError::Reload if a producer could not be created, for example because the blob has no entry for one of the topic’s physical topics.

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.