Interface IKafkaConsumerStatisticsCallback

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

Namespace: Silverback.Messaging.Broker.Callbacks

Assembly: Silverback.Integration.Kafka.dll

Syntax

public interface IKafkaConsumerStatisticsCallback : IBrokerClientCallback

Methods

OnConsumerStatistics(KafkaStatistics?, string, IKafkaConsumer)

Called on statistics events.

Declaration

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

Parameters

Type	Name	Description
KafkaStatistics	statistics	The deserialized statistics.
string	rawStatistics	The raw statistics string.
IKafkaConsumer	consumer	The related consumer instance.

Remarks

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