Struct FetchRequestV16

Source

pub struct FetchRequestV16 {Show 13 fields
    pub correlation_id: i32,
    pub client_id: Option<String>,
    pub cluster_id: Option<String>,
    pub replica_state: Option<FetchReplicaStateV15>,
    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<FetchTopicV16>,
    pub forgotten_topics: Vec<FetchForgottenTopicV16>,
    pub rack_id: String,
}

Expand description

Fetch request version 16. Kafka 4.3 keeps the v15 request shape.

Fields§

§correlation_id: i32§client_id: Option<String>§cluster_id: Option<String>§replica_state: Option<FetchReplicaStateV15>§max_wait_ms: i32§min_bytes: i32§max_bytes: i32§isolation_level: i8§session_id: i32§session_epoch: i32§topics: Vec<FetchTopicV16>§forgotten_topics: Vec<FetchForgottenTopicV16>§rack_id: String

Struct FetchRequestV16 Copy item path

Fields§

Implementations§

impl FetchRequestV16

pub fn encode(&self) -> Result<Vec<u8>>

Trait Implementations§

impl Clone for FetchRequestV16

fn clone(&self) -> FetchRequestV16

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

impl Debug for FetchRequestV16

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

impl Eq for FetchRequestV16

impl PartialEq for FetchRequestV16

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

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

impl StructuralPartialEq for FetchRequestV16

Auto Trait Implementations§

impl Freeze for FetchRequestV16

impl RefUnwindSafe for FetchRequestV16

impl Send for FetchRequestV16

impl Sync for FetchRequestV16

impl Unpin for FetchRequestV16

impl UnsafeUnpin for FetchRequestV16

impl UnwindSafe for FetchRequestV16

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Struct FetchRequestV16

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,