Class KafkaConsumerLocalTimeoutMonitor

Handles the consumer error callback and reverts the consumer Ready status to Connected 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

IBrokerCallback

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Silverback.Messaging.Broker

Assembly: Silverback.Integration.Kafka.dll

Syntax

public class KafkaConsumerLocalTimeoutMonitor : IKafkaConsumerLogCallback, IBrokerCallback

Methods

OnConsumerLog(LogMessage, KafkaConsumer)

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

Declaration

public bool OnConsumerLog(LogMessage logMessage, KafkaConsumer consumer)

Parameters

Type	Name	Description
LogMessage	logMessage	The Confluent.Kafka.LogMessage.
KafkaConsumer	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

IBrokerCallback