Struct ConsumerBuilder

pub struct ConsumerBuilder {
    last_high_watermark: Option<i64>,
    client: Option<Arc<dyn FetchClient>>,
    max_batch_size: Option<usize>,
    max_wait_ms: Option<u32>,
    avg_record_size: Option<usize>,
    terminated: Option<bool>,
    buffer: Option<RecordsBuffer>,
    fetch_fut: Option<Fuse<BoxFuture<'static, Result<FetchResult>>>>,
}

Builder for Consumer.

Fields

last_high_watermark: Option<i64>

client: Option<Arc<dyn FetchClient>>

The client is used to fetch records from kafka topic.

max_batch_size: Option<usize>

The max batch size in a single fetch request.

max_wait_ms: Option<u32>

The max wait milliseconds.

avg_record_size: Option<usize>

The avg record size

terminated: Option<bool>

Termination flag

buffer: Option<RecordsBuffer>

The buffer of records.

fetch_fut: Option<Fuse<BoxFuture<'static, Result<FetchResult>>>>

The fetch future.

Implementations

impl ConsumerBuilder

pub fn last_high_watermark(self, value: i64) -> Self

pub fn client(self, value: Arc<dyn FetchClient>) -> Self

The client is used to fetch records from kafka topic.

pub fn max_batch_size(self, value: usize) -> Self

The max batch size in a single fetch request.

pub fn max_wait_ms(self, value: u32) -> Self

The max wait milliseconds.

pub fn avg_record_size(self, value: usize) -> Self

The avg record size

pub fn terminated(self, value: bool) -> Self

Termination flag

pub fn buffer(self, value: RecordsBuffer) -> Self

The buffer of records.

pub fn fetch_fut( self, value: Fuse<BoxFuture<'static, Result<FetchResult>>>, ) -> Self

The fetch future.

pub fn build(self) -> Result<Consumer, ConsumerBuilderError>

Builds a new Consumer.

Errors

If a required field has not been initialized.

fn create_empty() -> Self

Create an empty builder, with all fields set to None or PhantomData.

Trait Implementations

impl Default for ConsumerBuilder

fn default() -> Self

Returns the “default value” for a type.