PendingOffsetsStatisticsHandler constructor

Initializes a new instance of the PendingOffsetsStatisticsHandler class with the specified handler and interval.

public PendingOffsetsStatisticsHandler(
    Action<IDependencyResolver, IEnumerable<TopicPartitionOffset>> handler, TimeSpan interval)

parameter	description
handler	The action to handle pending offsets statistics.
interval	The interval at which the handler should be executed.

See Also

• class PendingOffsetsStatisticsHandler
• namespace KafkaFlow.Configuration