Interface IKafkaConsumerStatisticsCallback
Declares the OnConsumerStatistics(KafkaStatistics, String, KafkaConsumer) event handler.
Namespace: Silverback.Messaging.Broker.Callbacks
Assembly: Silverback.Integration.Kafka.dll
Syntax
public interface IKafkaConsumerStatisticsCallback : IBrokerCallbackMethods
| Improve this doc View sourceOnConsumerStatistics(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. |
| System.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).