Struct samsa::prelude::protocol::OffsetFetchRequest

pub struct OffsetFetchRequest<'a> {
    pub header: HeaderRequest<'a>,
    pub group_id: &'a str,
    pub topics: Vec<Topic<'a>>,
}

The base Offset Fetch request object.

Example

let mut offset_request = protocol::OffsetFetchRequest::new(correlation_id, client_id, group_id);
coordinator_conn.send_request(&offset_request).await?;

Fields

header: HeaderRequest<'a>

group_id: &'a str

The group to fetch offsets for.

topics: Vec<Topic<'a>>

Each topic we would like to fetch offsets for, or null to fetch offsets for all topics.

Implementations

impl<'a> OffsetFetchRequest<'a>

pub fn new(correlation_id: i32, client_id: &'a str, group_id: &'a str) -> Self

pub fn add(&mut self, topic_name: &'a str, partition_index: i32)

Trait Implementations

impl<'a> Debug for OffsetFetchRequest<'a>

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

Formats the value using the given formatter.

impl<'a> ToByte for OffsetFetchRequest<'a>

fn encode<T: BufMut>(&self, buffer: &mut T) -> Result<()>