Struct FetchRequest 

pub struct FetchRequest {
    pub replica_id: i32,
    pub max_wait_ms: i32,
    pub min_bytes: i32,
    pub max_bytes: i32,
    pub isolation_level: i8,
    pub session_id: i32,
    pub session_epoch: i32,
    pub topics: Vec<FetchTopic>,
    pub forgotten_topics_data: Vec<ForgottenTopic>,
}

FetchRequest, version 8.

Fields

replica_id: i32

The broker ID of the follower, of -1 if this request is from a consumer.

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.

isolation_level: i8

This setting controls the visibility of transactional records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records visible. With READ_COMMITTED (isolation_level = 1), non-transactional and COMMITTED transactional records are visible. To be more concrete, READ_COMMITTED returns all data from offsets smaller than the current LSO (last stable offset), and enables the inclusion of the list of aborted transactions in the result, which allows consumers to discard ABORTED transactional records.

session_id: i32

The fetch session ID.

session_epoch: i32

The fetch session epoch, which is used for ordering requests in a session.

topics: Vec<FetchTopic>

The topics to fetch.

forgotten_topics_data: Vec<ForgottenTopic>

In an incremental fetch request, the partitions to remove.

Implementations

impl FetchRequest

pub fn new( replica_id: i32, max_wait_ms: i32, min_bytes: i32, max_bytes: i32, isolation_level: i8, session_id: i32, session_epoch: i32, topics: Vec<FetchTopic>, forgotten_topics_data: Vec<ForgottenTopic>, ) -> Self

Trait Implementations

impl ApiMessage for FetchRequest

fn api_key(&self) -> i16

The API key of this API message.

fn version(&self) -> i16

The version of this API message.

impl Clone for FetchRequest

fn clone(&self) -> FetchRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FetchRequest

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

Formats the value using the given formatter.

impl Default for FetchRequest

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FetchRequest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for FetchRequest

fn eq(&self, other: &FetchRequest) -> 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 Readable for FetchRequest

fn read(input: &mut impl Read) -> Result<Self>

Read this entity from a Read.

fn read_ext( input: &mut impl Read, field_name: &str, compact: bool, ) -> Result<Self>

Read this entity from a Read specifying the field name and controlling compactness.

impl Serialize for FetchRequest

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Writable for FetchRequest

fn write(&self, output: &mut impl Write) -> Result<()>

Write this entity to a Write.

fn write_ext( &self, output: &mut impl Write, field_name: &str, compact: bool, ) -> Result<()>

Write this entity to a Write specifying the field name and controlling compactness.

impl Request for FetchRequest

impl StructuralPartialEq for FetchRequest