Struct kafka_rs::client::Client

pub struct Client { /* private fields */ }

A Kafka client.

This client is Send + Sync + Clone, and cloning this client to share it among application tasks is encouraged.

This client spawns a task which manages the full lifecycle of interaction with a Kafka cluster, include initial broker connections based on seed list, cluster metadata discovery, connections to new brokers, establish API versions of brokers, handling reconnects, and anything else related to maintain connections to a Kafka cluster.

Implementations

impl Client

pub fn new(seed_list: Vec<String>) -> Self

Construct a new instance.

pub fn topic_producer( &self, topic: &str, acks: Acks, timeout_ms: Option<i32>, compression: Option<Compression> ) -> TopicProducer

Build a producer for a topic.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.