Table of Contents

Class KafkaLogEvents

Namespace
Silverback.Diagnostics
Assembly
Silverback.Integration.Kafka.dll

Contains the LogEvent constants of all events logged by the Silverback.Integration.Kafka package.

public static class KafkaLogEvents
Inheritance
KafkaLogEvents
Inherited Members

Properties

ConfluentAdminClientError

Gets the LogEvent representing the log that is written when a non-fatal error is reported by the Confluent.Kafka.IAdminClient.

public static LogEvent ConfluentAdminClientError { get; }

Property Value

LogEvent

Remarks

Fatal errors are reported with a different event id.

ConfluentAdminClientFatalError

Gets the LogEvent representing the log that is written when a fatal error is reported by the Confluent.Kafka.IAdminClient.

public static LogEvent ConfluentAdminClientFatalError { get; }

Property Value

LogEvent

Remarks

Non-fatal errors are reported with a different event id.

ConfluentAdminClientLogCritical

Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.IAdminClient.

public static LogEvent ConfluentAdminClientLogCritical { get; }

Property Value

LogEvent

Remarks

A different event id is used per each log level.

ConfluentAdminClientLogDebug

Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.IAdminClient.

public static LogEvent ConfluentAdminClientLogDebug { get; }

Property Value

LogEvent

Remarks

A different event id is used per each log level.

ConfluentAdminClientLogError

Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.IAdminClient.

public static LogEvent ConfluentAdminClientLogError { get; }

Property Value

LogEvent

Remarks

A different event id is used per each log level.

ConfluentAdminClientLogInformation

Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.IAdminClient.

public static LogEvent ConfluentAdminClientLogInformation { get; }

Property Value

LogEvent

Remarks

A different event id is used per each log level.

ConfluentAdminClientLogWarning

Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.IAdminClient.

public static LogEvent ConfluentAdminClientLogWarning { get; }

Property Value

LogEvent

Remarks

A different event id is used per each log level.

ConfluentConsumerError

Gets the LogEvent representing the log that is written when a non-fatal error is reported by the Confluent.Kafka.IConsumer<TKey, TValue>.

public static LogEvent ConfluentConsumerError { get; }

Property Value

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.IConsumer<TKey, TValue>.

public static LogEvent ConfluentConsumerFatalError { get; }

Property Value

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.IConsumer<TKey, TValue>.

public static LogEvent ConfluentConsumerLogCritical { get; }

Property Value

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.IConsumer<TKey, TValue>.

public static LogEvent ConfluentConsumerLogDebug { get; }

Property Value

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.IConsumer<TKey, TValue>.

public static LogEvent ConfluentConsumerLogError { get; }

Property Value

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.IConsumer<TKey, TValue>.

public static LogEvent ConfluentConsumerLogInformation { get; }

Property Value

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.IConsumer<TKey, TValue>.

public static LogEvent ConfluentConsumerLogWarning { get; }

Property Value

LogEvent

Remarks

A different event id is used per each log level.

ConfluentProducerError

Gets the LogEvent representing the log that is written when a non-fatal error is reported by the Confluent.Kafka.IProducer<TKey, TValue>.

public static LogEvent ConfluentProducerError { get; }

Property Value

LogEvent

Remarks

Fatal errors are reported with a different event id.

ConfluentProducerFatalError

Gets the LogEvent representing the log that is written when a fatal error is reported by the Confluent.Kafka.IProducer<TKey, TValue>.

public static LogEvent ConfluentProducerFatalError { get; }

Property Value

LogEvent

Remarks

Non-fatal errors are reported with a different event id.

ConfluentProducerLogCritical

Gets the LogEvent representing the log that is written when a log event is received from the underlying Confluent.Kafka.IProducer<TKey, TValue>.

public static LogEvent ConfluentProducerLogCritical { get; }

Property Value

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.IProducer<TKey, TValue>.

public static LogEvent ConfluentProducerLogDebug { get; }

Property Value

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.IProducer<TKey, TValue>.

public static LogEvent ConfluentProducerLogError { get; }

Property Value

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.IProducer<TKey, TValue>.

public static LogEvent ConfluentProducerLogInformation { get; }

Property Value

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.IProducer<TKey, TValue>.

public static LogEvent ConfluentProducerLogWarning { get; }

Property Value

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.

public static LogEvent ConsumerStatisticsReceived { get; }

Property Value

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

public static LogEvent ConsumingCanceled { get; }

Property Value

LogEvent

ConsumingMessage

Gets the LogEvent representing the log that is written when a message is consumed from a Kafka topic.

public static LogEvent ConsumingMessage { get; }

Property Value

LogEvent

EndOfPartition

Gets the LogEvent representing the log that is written when the end of partition is reached.

public static LogEvent EndOfPartition { get; }

Property Value

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

public static LogEvent KafkaExceptionAutoRecovery { get; }

Property Value

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

public static LogEvent KafkaExceptionNoAutoRecovery { get; }

Property Value

LogEvent

OffsetCommitError

Gets the LogEvent representing the log that is written when an error occurs committing the offset.

public static LogEvent OffsetCommitError { get; }

Property Value

LogEvent

OffsetCommitted

Gets the LogEvent representing the log that is written when an offset is successfully committed.

public static LogEvent OffsetCommitted { get; }

Property Value

LogEvent

OffsetSentToTransaction

Gets the LogEvent representing the log that is written when an offset is sent to the transaction.

public static LogEvent OffsetSentToTransaction { get; }

Property Value

LogEvent

PartitionAssigned

Gets the LogEvent representing the log that is written when a new consumer group partition assignment has been received by a consumer.

public static LogEvent PartitionAssigned { get; }

Property Value

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.

public static LogEvent PartitionOffsetReset { get; }

Property Value

LogEvent

PartitionPaused

Gets the LogEvent representing the log that is written when a partition is paused.

public static LogEvent PartitionPaused { get; }

Property Value

LogEvent

PartitionResumed

Gets the LogEvent representing the log that is written when a partition is resumed.

public static LogEvent PartitionResumed { get; }

Property Value

LogEvent

PartitionRevoked

Gets the LogEvent representing the log that is written when a group partition assignment is being revoked.

public static LogEvent PartitionRevoked { get; }

Property Value

LogEvent

Remarks

An event will be logged for each revoked partition.

PartitionStaticallyAssigned

Gets the LogEvent representing the log that is written when a static partition assignment is set for the consumer.

public static LogEvent PartitionStaticallyAssigned { get; }

Property Value

LogEvent

Remarks

An event will be logged for each assigned partition.

PollTimeoutAutoRecovery

Gets the LogEvent representing the log that is written when a poll timeout is notified. The consumer will automatically recover from this situation (EnableAutoRecovery is true).

public static LogEvent PollTimeoutAutoRecovery { get; }

Property Value

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

public static LogEvent PollTimeoutNoAutoRecovery { get; }

Property Value

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.

public static LogEvent ProduceNotAcknowledged { get; }

Property Value

LogEvent

ProducerStatisticsReceived

Gets the LogEvent representing the log that is written when the producer statistics are received.

public static LogEvent ProducerStatisticsReceived { get; }

Property Value

LogEvent

StaleConsumer

Gets the LogEvent representing the log that is written when the consumer did not consume any message within the stall detection threshold.

public static LogEvent StaleConsumer { get; }

Property Value

LogEvent

StatisticsDeserializationError

Gets the LogEvent representing the log that is written when the statistics JSON cannot be deserialized.

public static LogEvent StatisticsDeserializationError { get; }

Property Value

LogEvent

TransactionAborted

Gets the LogEvent representing the log that is written when a transaction is aborted.

public static LogEvent TransactionAborted { get; }

Property Value

LogEvent

TransactionCommitted

Gets the LogEvent representing the log that is written when a transaction is committed.

public static LogEvent TransactionCommitted { get; }

Property Value

LogEvent

TransactionStarted

Gets the LogEvent representing the log that is written when a new transaction is started.

public static LogEvent TransactionStarted { get; }

Property Value

LogEvent

TransactionsInitialized

Gets the LogEvent representing the log that is written when the transactional producer has been initialized.

public static LogEvent TransactionsInitialized { get; }

Property Value

LogEvent