IConsumerFlowManager interface
The consumer flow manager
public interface IConsumerFlowManager
Members
name | description |
---|---|
PausedPartitions { get; } | Gets a list of the consumer paused partitions |
Pause(…) | Pauses a set of partitions |
Resume(…) | Resumes a set of partitions |
See Also
- namespace KafkaFlow.Consumers