Interface IKafkaConsumerStatisticsCallback

Namespace

Silverback.Messaging.Broker.Callbacks

Assembly

Silverback.Integration.Kafka.dll

Declares the OnConsumerStatistics(KafkaStatistics?, string, IKafkaConsumer) event handler.

public interface IKafkaConsumerStatisticsCallback : IBrokerClientCallback

Methods

OnConsumerStatistics(KafkaStatistics?, string, IKafkaConsumer)

Called on statistics events.

void OnConsumerStatistics(KafkaStatistics? statistics, string rawStatistics, IKafkaConsumer consumer)

Parameters

statistics KafkaStatistics

The deserialized statistics.

rawStatistics string

The raw statistics string.

consumer IKafkaConsumer

The related consumer instance.

Remarks

You can enable statistics and set the statistics interval using the StatisticsIntervalMs configuration property (disabled by default).