pub struct OffsetCommit {
pub topic: String,
pub partition: i32,
pub offset: i64,
}Expand description
A Kafka commit position. offset is the next offset to consume.
Fields§
§topic: String§partition: i32§offset: i64Implementations§
Source§impl OffsetCommit
impl OffsetCommit
pub fn topic_partition(&self) -> TopicPartition
Trait Implementations§
Source§impl Clone for OffsetCommit
impl Clone for OffsetCommit
Source§fn clone(&self) -> OffsetCommit
fn clone(&self) -> OffsetCommit
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for OffsetCommit
impl Debug for OffsetCommit
impl Eq for OffsetCommit
Source§impl PartialEq for OffsetCommit
impl PartialEq for OffsetCommit
impl StructuralPartialEq for OffsetCommit
Auto Trait Implementations§
impl Freeze for OffsetCommit
impl RefUnwindSafe for OffsetCommit
impl Send for OffsetCommit
impl Sync for OffsetCommit
impl Unpin for OffsetCommit
impl UnsafeUnpin for OffsetCommit
impl UnwindSafe for OffsetCommit
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage