[−][src]Struct kafka::client::fetch::Response
The result of a "fetch messages" request from a particular Kafka broker. Such a response can contain messages for multiple topic partitions.
Methods
impl Response[src]
pub fn correlation_id(&self) -> i32[src]
Retrieves the id corresponding to the fetch messages request (provided for debugging purposes only).
pub fn topics<'a>(&'a self) -> &[Topic<'a>][src]
Provides an iterator over all the topics and the fetched data relative to these topics.
Trait Implementations
Auto Trait Implementations
impl Unpin for Response
impl !Sync for Response
impl Send for Response
impl !UnwindSafe for Response
impl !RefUnwindSafe for Response
Blanket Implementations
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T> From<T> for T[src]
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>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,