Struct kf_protocol::message::offset::KfListOffsetRequest

pub struct KfListOffsetRequest {
    pub replica_id: i32,
    pub isolation_level: Isolation,
    pub topics: Vec<ListOffsetTopic>,
}

Fields

replica_id: i32

The broker ID of the requestor, or -1 if this request is being made by a normal consumer.

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

topics: Vec<ListOffsetTopic>

Each topic in the request.

Trait Implementations

impl Debug for KfListOffsetRequest

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

Formats the value using the given formatter.

impl Decoder for KfListOffsetRequest

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 Default for KfListOffsetRequest

fn default() -> KfListOffsetRequest

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for KfListOffsetRequest

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

Deserialize this value from the given Serde deserializer.

impl Encoder for KfListOffsetRequest

fn encode<T>(&self, src: &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 Request for KfListOffsetRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfListOffsetResponse

impl Serialize for KfListOffsetRequest

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.