pub enum PartitionSelectionStrategy {
All(String),
Multiple(Vec<(String, PartitionId)>),
}
Expand description
Strategy used to select which partitions and from which topics should be streamed by the MultiplePartitionConsumer
Variants§
All(String)
Consume from all the partitions of a given topic
Multiple(Vec<(String, PartitionId)>)
Consume from a given list of topics and partitions
Trait Implementations§
source§impl Clone for PartitionSelectionStrategy
impl Clone for PartitionSelectionStrategy
source§fn clone(&self) -> PartitionSelectionStrategy
fn clone(&self) -> PartitionSelectionStrategy
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations§
impl Freeze for PartitionSelectionStrategy
impl RefUnwindSafe for PartitionSelectionStrategy
impl Send for PartitionSelectionStrategy
impl Sync for PartitionSelectionStrategy
impl Unpin for PartitionSelectionStrategy
impl UnwindSafe for PartitionSelectionStrategy
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