IConsumer.OnStatistics method
Register a handler to be executed to receive statistics information
public void OnStatistics(Action<IConsumer<byte[], byte[]>, string> handler)
parameter | description |
---|---|
handler | The handler that will be executed |
See Also
- interface IConsumer
- namespace KafkaFlow.Consumers