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.
Inherited Members
Namespace: Silverback.Messaging.Broker
Assembly: Silverback.Integration.Kafka.dll
Syntax
public class KafkaConsumerLocalTimeoutMonitor : IKafkaConsumerLogCallback, IBrokerCallback
Methods
| Improve this doc View sourceOnConsumerLog(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 |