Struct KafkaClient 

pub struct KafkaClient { /* private fields */ }

A small builder facade around one or more bootstrap servers.

Implementations

impl KafkaClient

pub fn new(bootstrap_server: impl Into<String>) -> Self

Creates a client facade from one bootstrap server.

pub fn with_bootstrap_servers( self, servers: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Sets bootstrap servers and returns the updated value.

pub fn topic(&self, topic: impl Into<String>) -> KafkaTopic

Returns a topic-scoped builder facade.

pub fn topics<I, S>(&self, topics: I) -> KafkaTopics

where I: IntoIterator<Item = S>, S: Into<String>,

Returns a multi-topic builder facade.

pub fn producer(&self) -> ProducerBuilder

Starts building a producer.

pub fn admin(&self) -> AdminBuilder

Starts building an admin client.

pub fn consumer(&self, group_id: impl Into<String>) -> ConsumerBuilder

Starts building a group consumer.

Trait Implementations

impl Clone for KafkaClient

fn clone(&self) -> KafkaClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaClient

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

Formats the value using the given formatter.