Interface IKafkaConsumerErrorCallback

Declares the OnConsumerError(Error, IKafkaConsumer) event handler.

Namespace: Silverback.Messaging.Broker.Callbacks

Assembly: Silverback.Integration.Kafka.dll

Syntax

public interface IKafkaConsumerErrorCallback : IBrokerClientCallback

Methods

OnConsumerError(Error, IKafkaConsumer)

Called when an error is reported by the underlying consumer.

Declaration

bool OnConsumerError(Error error, IKafkaConsumer consumer)

Parameters

Type	Name	Description
Error	error	An Confluent.Kafka.Error containing the error details.
IKafkaConsumer	consumer	The related consumer instance.

Returns

Type	Description
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.