Interface IKafkaProducerStatisticsCallback

Declares the OnProducerStatistics(KafkaStatistics?, string, IConfluentProducerWrapper) event handler.

Namespace: Silverback.Messaging.Broker.Callbacks

Assembly: Silverback.Integration.Kafka.dll

Syntax

public interface IKafkaProducerStatisticsCallback : IBrokerClientCallback

Methods

OnProducerStatistics(KafkaStatistics?, string, IConfluentProducerWrapper)

Called on statistics events.

Declaration

void OnProducerStatistics(KafkaStatistics? statistics, string rawStatistics, IConfluentProducerWrapper producerWrapper)

Parameters

Type	Name	Description
KafkaStatistics	statistics	The deserialized statistics.
string	rawStatistics	The raw statistics string.
IConfluentProducerWrapper	producerWrapper	The related IConfluentProducerWrapper.

Remarks

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