Package io.kroxylicious.proxy.internal.codec

Interface KafkaMessageListener

All Known Implementing Classes:
MetricEmittingKafkaMessageListener
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface KafkaMessageListener
Callback invoked by the KafkaMessageEncoder and KafkaMessageDecoder on encode or decode of each message.

  • Method Summary

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

  • Method Details

    • onMessage

      void onMessage(Frame frame, int wireLength)
      Called each time a kafka message is encoded or decoded.
      Parameters:
      frame - - frame object
      wireLength - this is the message size plus the Frame.FRAME_SIZE_LENGTH.