[−][src]Struct kf_protocol_message::offset::KfListOffsetRequest
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
[src]
impl Decoder for KfListOffsetRequest
[src]
fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error> where
T: Buf,
[src]
T: Buf,
fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error> where
Self: Default,
T: Buf,
[src]
Self: Default,
T: Buf,
impl Default for KfListOffsetRequest
[src]
impl<'de> Deserialize<'de> for KfListOffsetRequest
[src]
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Encoder for KfListOffsetRequest
[src]
fn encode<T>(&self, src: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
fn as_bytes(&self, version: i16) -> Result<Bytes, Error>
[src]
impl Request for KfListOffsetRequest
[src]
const API_KEY: u16
[src]
const MIN_API_VERSION: i16
[src]
const MAX_API_VERSION: i16
[src]
const DEFAULT_API_VERSION: i16
[src]
type Response = KfListOffsetResponse
impl Serialize for KfListOffsetRequest
[src]
Auto Trait Implementations
impl RefUnwindSafe for KfListOffsetRequest
impl Send for KfListOffsetRequest
impl Sync for KfListOffsetRequest
impl Unpin for KfListOffsetRequest
impl UnwindSafe for KfListOffsetRequest
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
T: for<'de> Deserialize<'de>,
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,