Struct ShareFetchRequestData 

pub struct ShareFetchRequestData {

    pub group_id: Option<KafkaString>,
    pub member_id: Option<KafkaString>,
    pub share_session_epoch: i32,
    pub max_wait_ms: i32,
    pub min_bytes: i32,
    pub max_bytes: i32,
    pub max_records: i32,
    pub batch_size: i32,
    pub share_acquire_mode: i8,
    pub is_renew_ack: bool,
    pub topics: Vec<FetchTopic>,
    pub forgotten_topics_data: Vec<ForgottenTopic>,
    pub _unknown_tagged_fields: Vec<RawTaggedField>,
}

Fields

group_id: Option<KafkaString>

The group identifier.

member_id: Option<KafkaString>

The member ID.

share_session_epoch: i32

The current share session epoch: 0 to open a share session; -1 to close it; otherwise increments for consecutive requests.

max_wait_ms: i32

The maximum time in milliseconds to wait for the response.

min_bytes: i32

The minimum bytes to accumulate in the response.

max_bytes: i32

The maximum bytes to fetch. See KIP-74 for cases where this limit may not be honored.

max_records: i32

The maximum number of records to fetch. This limit can be exceeded for alignment of batch boundaries.

batch_size: i32

The optimal number of records for batches of acquired records and acknowledgements.

share_acquire_mode: i8

The acquire mode to control the fetch behavior - 0:batch-optimized,1:record-limit.

is_renew_ack: bool

Whether Renew type acknowledgements present in AcknowledgementBatches.

topics: Vec<FetchTopic>

The topics to fetch.

forgotten_topics_data: Vec<ForgottenTopic>

The partitions to remove from this share session.

_unknown_tagged_fields: Vec<RawTaggedField>

Implementations

impl ShareFetchRequestData

pub fn with_group_id(self, value: Option<KafkaString>) -> Self

pub fn with_member_id(self, value: Option<KafkaString>) -> Self

pub fn with_share_session_epoch(self, value: i32) -> Self

pub fn with_max_wait_ms(self, value: i32) -> Self

pub fn with_min_bytes(self, value: i32) -> Self

pub fn with_max_bytes(self, value: i32) -> Self

pub fn with_max_records(self, value: i32) -> Self

pub fn with_batch_size(self, value: i32) -> Self

pub fn with_share_acquire_mode(self, value: i8) -> Self

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

pub fn with_topics(self, value: Vec<FetchTopic>) -> Self

pub fn with_forgotten_topics_data(self, value: Vec<ForgottenTopic>) -> Self

pub fn read(buf: &mut Bytes, version: i16) -> Result<Self>

pub fn write(&self, buf: &mut BytesMut, version: i16) -> Result<()>

pub fn encoded_len(&self, version: i16) -> Result<usize>

Trait Implementations

impl Clone for ShareFetchRequestData

fn clone(&self) -> ShareFetchRequestData

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ShareFetchRequestData

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

Formats the value using the given formatter.

impl Default for ShareFetchRequestData

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for ShareFetchRequestData

fn eq(&self, other: &ShareFetchRequestData) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ShareFetchRequestData