Package io.kroxylicious.proxy.internal.metrics

Class MetricEmittingKafkaMessageListener

java.lang.Object
io.kroxylicious.proxy.internal.metrics.MetricEmittingKafkaMessageListener
All Implemented Interfaces:
KafkaMessageListener
public class MetricEmittingKafkaMessageListener extends Object implements KafkaMessageListener
A kafka message listener that emits message count and message size metrics.

  • Constructor Summary

    Constructors
    Constructor
    Description
    MetricEmittingKafkaMessageListener(io.micrometer.core.instrument.Meter.MeterProvider<io.micrometer.core.instrument.Counter> messageCounterProvider, io.micrometer.core.instrument.Meter.MeterProvider<io.micrometer.core.instrument.DistributionSummary> messageSizeProvider)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onMessage(Frame frame, int wireLength)
    Called each time a kafka message is encoded or decoded.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • MetricEmittingKafkaMessageListener

      public MetricEmittingKafkaMessageListener(io.micrometer.core.instrument.Meter.MeterProvider<io.micrometer.core.instrument.Counter> messageCounterProvider, io.micrometer.core.instrument.Meter.MeterProvider<io.micrometer.core.instrument.DistributionSummary> messageSizeProvider)

  • Method Details