pub struct AcknowledgeTopic {
pub topic_id: KafkaUuid,
pub partitions: Vec<AcknowledgePartition>,
pub _unknown_tagged_fields: Vec<RawTaggedField>,
}Fields§
§topic_id: KafkaUuidThe unique topic ID.
partitions: Vec<AcknowledgePartition>The partitions containing records to acknowledge.
_unknown_tagged_fields: Vec<RawTaggedField>Implementations§
Source§impl AcknowledgeTopic
impl AcknowledgeTopic
pub fn with_topic_id(self, value: KafkaUuid) -> Self
pub fn with_partitions(self, value: Vec<AcknowledgePartition>) -> Self
pub fn read(buf: &mut Bytes, version: i16) -> Result<Self>
pub fn write(&self, buf: &mut BytesMut, version: i16) -> Result<()>
pub fn encoded_len(&self, version: i16) -> Result<usize>
Trait Implementations§
Source§impl Clone for AcknowledgeTopic
impl Clone for AcknowledgeTopic
Source§fn clone(&self) -> AcknowledgeTopic
fn clone(&self) -> AcknowledgeTopic
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 AcknowledgeTopic
impl Debug for AcknowledgeTopic
Source§impl Default for AcknowledgeTopic
impl Default for AcknowledgeTopic
Source§impl PartialEq for AcknowledgeTopic
impl PartialEq for AcknowledgeTopic
Source§fn eq(&self, other: &AcknowledgeTopic) -> bool
fn eq(&self, other: &AcknowledgeTopic) -> bool
Tests for
self and other values to be equal, and is used by ==.impl StructuralPartialEq for AcknowledgeTopic
Auto Trait Implementations§
impl Freeze for AcknowledgeTopic
impl RefUnwindSafe for AcknowledgeTopic
impl Send for AcknowledgeTopic
impl Sync for AcknowledgeTopic
impl Unpin for AcknowledgeTopic
impl UnsafeUnpin for AcknowledgeTopic
impl UnwindSafe for AcknowledgeTopic
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