Class KafkaLogEvents
Contains the LogEvent constants of all events logged by the Silverback.Integration.Kafka package.
Inherited Members
Namespace: Silverback.Diagnostics
Assembly: Silverback.Integration.Kafka.dll
Syntax
public static class KafkaLogEvents
Properties
| Improve this doc View sourceConfluentConsumerDisconnectError
Gets the LogEvent representing the log that is written when an exception is thrown disconnecting the underlying Confluent.Kafka consumer.
Declaration
public static LogEvent ConfluentConsumerDisconnectError { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
ConfluentConsumerError
Gets the LogEvent representing the log that is written when a non fatal error is reported by the Confluent.Kafka.Consumer<TKey, TValue>.
Declaration
public static LogEvent ConfluentConsumerError { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
Fatal errors are reported with a different event id.
ConfluentConsumerFatalError
Gets the LogEvent representing the log that is written when a fatal error is reported by the Confluent.Kafka.Consumer<TKey, TValue>.
Declaration
public static LogEvent ConfluentConsumerFatalError { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
Non fatal errors are reported with a different event id.
ConfluentConsumerLogCritical
Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.Consumer<TKey, TValue>.
Declaration
public static LogEvent ConfluentConsumerLogCritical { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
A different event id is used per each log level.
ConfluentConsumerLogDebug
Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.Consumer<TKey, TValue>.
Declaration
public static LogEvent ConfluentConsumerLogDebug { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
A different event id is used per each log level.
ConfluentConsumerLogError
Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.Consumer<TKey, TValue>.
Declaration
public static LogEvent ConfluentConsumerLogError { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
A different event id is used per each log level.
ConfluentConsumerLogInformation
Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.Consumer<TKey, TValue>.
Declaration
public static LogEvent ConfluentConsumerLogInformation { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
A different event id is used per each log level.
ConfluentConsumerLogWarning
Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.Consumer<TKey, TValue>.
Declaration
public static LogEvent ConfluentConsumerLogWarning { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
A different event id is used per each log level.
ConfluentProducerLogCritical
Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.Producer<TKey, TValue>.
Declaration
public static LogEvent ConfluentProducerLogCritical { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
A different event id is used per each log level.
ConfluentProducerLogDebug
Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.Producer<TKey, TValue>.
Declaration
public static LogEvent ConfluentProducerLogDebug { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
A different event id is used per each log level.
ConfluentProducerLogError
Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.Producer<TKey, TValue>.
Declaration
public static LogEvent ConfluentProducerLogError { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
A different event id is used per each log level.
ConfluentProducerLogInformation
Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.Producer<TKey, TValue>.
Declaration
public static LogEvent ConfluentProducerLogInformation { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
A different event id is used per each log level.
ConfluentProducerLogWarning
Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.Producer<TKey, TValue>.
Declaration
public static LogEvent ConfluentProducerLogWarning { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
A different event id is used per each log level.
ConsumerStatisticsReceived
Gets the LogEvent representing the log that is written when the consumer statistics are received.
Declaration
public static LogEvent ConsumerStatisticsReceived { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
ConsumingCanceled
Gets the LogEvent representing the log that is written when the Consume is aborted
(usually because the broker is being disconnected or the application is exiting).
Declaration
public static LogEvent ConsumingCanceled { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
ConsumingMessage
Gets the LogEvent representing the log that is written when a message is consumed from a Kafka topic.
Declaration
public static LogEvent ConsumingMessage { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
CreatingConfluentProducer
Gets the LogEvent representing the log that is written when the Confluent.Kafka.Producer<TKey, TValue> is being instantiated.
Declaration
public static LogEvent CreatingConfluentProducer { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
EndOfPartition
Gets the LogEvent representing the log that is written when the end of partition is reached.
Declaration
public static LogEvent EndOfPartition { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
ErrorRecoveringFromKafkaException
Gets the LogEvent representing the log that is written when the KafkaConsumer is unable to recover from the KafkaExceptionAutoRecovery.
Declaration
[Obsolete("Not used anymore.", true)]
public static LogEvent ErrorRecoveringFromKafkaException { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
KafkaErrorHandlerError
Gets the LogEvent representing the log that is written when the custom error handler throws an unhandled exception.
Declaration
public static LogEvent KafkaErrorHandlerError { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
KafkaExceptionAutoRecovery
Gets the LogEvent representing the log that is written when a
Confluent.Kafka.KafkaException is thrown inside the Consume method. The consumer
will automatically recover from these exceptions (EnableAutoRecovery is true).
Declaration
public static LogEvent KafkaExceptionAutoRecovery { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
KafkaExceptionNoAutoRecovery
Gets the LogEvent representing the log that is written when a
Confluent.Kafka.KafkaException is thrown inside the Consume method. The consumer
will be stopped (EnableAutoRecovery is false).
Declaration
public static LogEvent KafkaExceptionNoAutoRecovery { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
KafkaLogHandlerError
Gets the LogEvent representing the log that is written when the custom log handler throws an unhandled exception.
Declaration
public static LogEvent KafkaLogHandlerError { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
OffsetCommitError
Gets the LogEvent representing the log that is written when an error occurs while committing the offset.
Declaration
public static LogEvent OffsetCommitError { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
OffsetCommitted
Gets the LogEvent representing the log that is written when an offset is successfully committed.
Declaration
public static LogEvent OffsetCommitted { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
PartitionAssigned
Gets the LogEvent representing the log that is written when a new consumer group partition assignment has been received by a consumer.
Declaration
public static LogEvent PartitionAssigned { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
An event will be logged for each assigned partition.
PartitionManuallyAssigned
Gets the LogEvent representing the log that is written when the partitions are manually assigned.
Declaration
public static LogEvent PartitionManuallyAssigned { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
An event will be logged for each assigned partition.
PartitionOffsetReset
Gets the LogEvent representing the log that is written when the offset of an assigned partition is being reset.
Declaration
public static LogEvent PartitionOffsetReset { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
PartitionPaused
Gets the LogEvent representing the log that is written when a partition is paused.
Declaration
public static LogEvent PartitionPaused { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
PartitionResumed
Gets the LogEvent representing the log that is written when a partition is resumed.
Declaration
public static LogEvent PartitionResumed { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
PartitionRevoked
Gets the LogEvent representing the log that is written when a group partition assignment is being revoked.
Declaration
public static LogEvent PartitionRevoked { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
Remarks
An event will be logged for each revoked partition.
PollTimeoutAutoRecovery
Gets the LogEvent representing the log that is written when a poll timeout is notified.
The consumer will automatically recover from these situation (EnableAutoRecovery is true).
Declaration
public static LogEvent PollTimeoutAutoRecovery { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
PollTimeoutNoAutoRecovery
Gets the LogEvent representing the log that is written when a poll timeout is notified.
The consumer will be stopped (EnableAutoRecovery is false).
Declaration
public static LogEvent PollTimeoutNoAutoRecovery { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
ProduceNotAcknowledged
Gets the LogEvent representing the log that is written when the message is sent to the
broker but no acknowledge is received. This is logged only if ThrowIfNotAcknowledged is
false.
Declaration
public static LogEvent ProduceNotAcknowledged { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
ProducerStatisticsReceived
Gets the LogEvent representing the log that is written when the producer statistics are received.
Declaration
public static LogEvent ProducerStatisticsReceived { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |
StatisticsDeserializationError
Gets the LogEvent representing the log that is written when the statistics JSON cannot be deserialized.
Declaration
public static LogEvent StatisticsDeserializationError { get; }
Property Value
| Type | Description |
|---|---|
| LogEvent |