Enum fluvio::consumer::PartitionSelectionStrategy

pub enum PartitionSelectionStrategy {
    All(String),
    Multiple(Vec<(String, i32)>),
}

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

Tuple Fields of All

0: String

Multiple(Vec<(String, i32)>)

Consume from a given list of topics and partitions

Tuple Fields of Multiple

0: Vec<(String, i32)>