IMessageConsumer.RunningPartitions property

Gets the consumer's running partitions

public IEnumerable<TopicPartition> RunningPartitions \{ get; }

See Also

• interface IMessageConsumer
• namespace KafkaFlow.Consumers