IConsumer.OnError method

Register a handler to be executed when an error occurs

public void OnError(Action<IConsumer<byte[], byte[]>, Error> handler)

parameter	description
handler	The handler that will be executed

See Also

• interface IConsumer
• namespace KafkaFlow.Consumers