Interface IKafkaConsumerErrorCallback

Namespace

Silverback.Messaging.Broker.Callbacks

Assembly

Silverback.Integration.Kafka.dll

Declares the OnConsumerError(Error, IKafkaConsumer) event handler.

public interface IKafkaConsumerErrorCallback : IBrokerClientCallback

Methods

OnConsumerError(Error, IKafkaConsumer)

Called when an error is reported by the underlying consumer.

bool OnConsumerError(Error error, IKafkaConsumer consumer)

Parameters

error Error

An Confluent.Kafka.Error containing the error details.

consumer IKafkaConsumer

The related consumer instance.

Returns

bool

A value whether the error was handled. When true the error will not be logged nor handled in any other way by Silverback.

Remarks

Note that the system (either the Kafka client itself or Silverback) will try to automatically recover from all errors automatically, so these errors have to be considered mostly informational.