Class KafkaConsumerLocalTimeoutMonitor

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.

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()

Namespace: Silverback.Messaging.Broker

Assembly: Silverback.Integration.Kafka.dll

Syntax

public class KafkaConsumerLocalTimeoutMonitor : IKafkaConsumerLogCallback, IBrokerClientCallback

Constructors

KafkaConsumerLocalTimeoutMonitor()

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.

Declaration

public KafkaConsumerLocalTimeoutMonitor()

Methods

OnConsumerLog(LogMessage, IKafkaConsumer)

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

Declaration

public bool OnConsumerLog(LogMessage logMessage, IKafkaConsumer consumer)

Parameters

Type	Name	Description
LogMessage	logMessage	The Confluent.Kafka.LogMessage.
IKafkaConsumer	consumer	The related consumer instance.

Returns

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

Implements

IKafkaConsumerLogCallback

IBrokerClientCallback