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, i32)>)
Consume from a given list of topics and partitions
Auto Trait Implementations
impl RefUnwindSafe for PartitionSelectionStrategy
impl Send for PartitionSelectionStrategy
impl Sync for PartitionSelectionStrategy
impl Unpin for PartitionSelectionStrategy
impl UnwindSafe for PartitionSelectionStrategy
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more