IConsumerFlowManager.Pause method
Pauses a set of partitions
public void Pause(IReadOnlyCollection<TopicPartition> topicPartitions)
parameter | description |
---|---|
topicPartitions | A list of partitions |
See Also
- interface IConsumerFlowManager
- namespace KafkaFlow.Consumers