Struct kf_protocol::message::fetch::KfFetchRequest

pub struct KfFetchRequest<R> where
    R: Encoder + Decoder + Default + Debug,  {
    pub replica_id: i32,
    pub max_wait: i32,
    pub min_bytes: i32,
    pub max_bytes: i32,
    pub isolation_level: Isolation,
    pub session_id: i32,
    pub epoch: i32,
    pub topics: Vec<FetchableTopic>,
    pub forgotten: Vec<ForgottenTopic>,
    pub data: PhantomData<R>,
}

Fields

replica_id: i32

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

max_wait: 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: Isolation

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.

epoch: i32

The fetch session ID.

topics: Vec<FetchableTopic>

The topics to fetch.

forgotten: Vec<ForgottenTopic>

In an incremental fetch request, the partitions to remove.

data: PhantomData<R>

Trait Implementations

impl<R> Debug for KfFetchRequest<R> where
    R: Debug + Encoder + Decoder + Default, 

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

Formats the value using the given formatter.

impl<R> Decoder for KfFetchRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
    T: Buf, 

fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error> where
    Self: Default,
    T: Buf, 

decode Kafka compliant protocol values from buf

impl<R> Default for KfFetchRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

fn default() -> KfFetchRequest<R>

Returns the "default value" for a type.

impl<'de, R> Deserialize<'de> for KfFetchRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

fn deserialize<__D>(
    __deserializer: __D
) -> Result<KfFetchRequest<R>, <__D as Deserializer<'de>>::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<R> Encoder for KfFetchRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

encoding contents for buffer

fn write_size(&self, version: i16) -> usize

size of this object in bytes

fn as_bytes(&self, version: i16) -> Result<Bytes, Error>

impl<R> Request for KfFetchRequest<R> where
    R: Debug + Decoder + Encoder, 

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfFetchResponse<R>

impl<R> Serialize for KfFetchRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

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

Serialize this value into the given Serde serializer.