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