Interface IKafkaProducerStatisticsCallback

Namespace

Silverback.Messaging.Broker.Callbacks

Assembly

Silverback.Integration.Kafka.dll

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

public interface IKafkaProducerStatisticsCallback : IBrokerClientCallback

Methods

OnProducerStatistics(KafkaStatistics?, string, IConfluentProducerWrapper)

Called on statistics events.

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

Parameters

statistics KafkaStatistics

The deserialized statistics.

rawStatistics string

The raw statistics string.

producerWrapper IConfluentProducerWrapper

The related IConfluentProducerWrapper.

Remarks

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