Struct KafkaClient

pub struct KafkaClient { /* private fields */ }

Keeps all the configured kafka producers and responsible for the routing of the messages.

Implementations

impl KafkaClient

pub fn builder() -> KafkaClientBuilder

Returns the KafkaClientBuilder

pub fn send_message( &self, topic: KafkaTopic, message: &impl Message, ) -> Result<&str, ClientError>

Sends message to the provided kafka topic.

Returns the name of the kafka topic to which the message was produced.

pub fn send( &self, topic: KafkaTopic, key: &[u8; 16], headers: Option<&BTreeMap<String, String>>, variant: &str, payload: &[u8], ) -> Result<&str, ClientError>

Sends the payload to the correct producer for the current topic.

Returns the name of the kafka topic to which the message was produced.

Trait Implementations

impl Debug for KafkaClient

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

Formats the value using the given formatter.