Interface IKafkaConsumerErrorCallback

Declares the OnConsumerError(Error, KafkaConsumer) event handler.

Namespace: Silverback.Messaging.Broker.Callbacks

Assembly: Silverback.Integration.Kafka.dll

Syntax

public interface IKafkaConsumerErrorCallback : IBrokerCallback

Methods

| Improve this doc View source

OnConsumerError(Error, KafkaConsumer)

Called when an error is reported by the underlying consumer.

Declaration

bool OnConsumerError(Error error, KafkaConsumer consumer)

Parameters

Type	Name	Description
Error	error	An Confluent.Kafka.Error containing the error details.
KafkaConsumer	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.