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

System.Object

KafkaConsumerLocalTimeoutMonitor

Implements

IKafkaConsumerLogCallback

IBrokerCallback

Inherited Members

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.ToString()

Namespace: Silverback.Messaging.Broker

Assembly: Silverback.Integration.Kafka.dll

Syntax

public class KafkaConsumerLocalTimeoutMonitor : IKafkaConsumerLogCallback, IBrokerCallback

Methods

OnConsumerLog(LogMessage, KafkaConsumer)

Declaration

public bool OnConsumerLog(LogMessage logMessage, KafkaConsumer consumer)

Parameters

Type	Name	Description
Confluent.Kafka.LogMessage	logMessage
KafkaConsumer	consumer

Returns

Type	Description
System.Boolean

Implements

IKafkaConsumerLogCallback

IBrokerCallback