Struct 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 async fn get_metadata( &self, broker_id: i32, ) -> ClientResult<MetadataResponse>

Get cluster metadata from the broker specified by ID.

pub async fn list_offsets( &self, topic: StrBytes, ptn: i32, pos: ListOffsetsPosition, ) -> ClientResult<i64>

List topic partition offsets.

pub async fn fetch( &self, topic: StrBytes, ptn: i32, start: i64, ) -> ClientResult<Option<Vec<Record>>>

Fetch a batch of records from the target topic partition.

pub async fn find_coordinator( &self, key: StrBytes, key_type: i8, broker_id: Option<i32>, ) -> ClientResult<FindCoordinatorResponse>

Find the coordinator for the given group.

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

Build a producer for a topic.

pub fn admin(&self) -> Admin

Build an admin client.

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.