Class KafkaConsumerLocalTimeoutMonitor

Namespace

Silverback.Messaging.Broker

Assembly

Silverback.Integration.Kafka.dll

Handles the consumer error callback and reverts the consumer Connected status to Started when the local poll timeout is exceeded. The consumer should eventually reconnect but this allows to accurately track its status.

public class KafkaConsumerLocalTimeoutMonitor : IKafkaConsumerLogCallback, IBrokerClientCallback

Inheritance

object

KafkaConsumerLocalTimeoutMonitor

Implements

IKafkaConsumerLogCallback

IBrokerClientCallback

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

KafkaConsumerLocalTimeoutMonitor()

public KafkaConsumerLocalTimeoutMonitor()

Methods

OnConsumerLog(LogMessage, IKafkaConsumer)

Called when a log message is being reported by the underlying consumer.

public bool OnConsumerLog(LogMessage logMessage, IKafkaConsumer consumer)

Parameters

logMessage LogMessage

The Confluent.Kafka.LogMessage.

consumer IKafkaConsumer

The related consumer instance.

Returns

bool

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