Interface IKafkaConsumerStatisticsCallback

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

Namespace: Silverback.Messaging.Broker.Callbacks
Assembly: Silverback.Integration.Kafka.dll
Syntax
public interface IKafkaConsumerStatisticsCallback : IBrokerCallback

Methods

| Improve this doc View source

OnConsumerStatistics(KafkaStatistics?, string, KafkaConsumer)

Called on statistics events.

Declaration
void OnConsumerStatistics(KafkaStatistics? statistics, string rawStatistics, KafkaConsumer consumer)
Parameters
Type Name Description
KafkaStatistics statistics

The deserialized statistics.
string rawStatistics

The raw statistics string.
KafkaConsumer consumer

The related consumer instance.
Remarks

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