Package io.kroxylicious.proxy.frame

Class BareSaslRequest

java.lang.Object
io.kroxylicious.proxy.frame.BareSaslRequest
All Implemented Interfaces:
Frame, RequestFrame
public class BareSaslRequest extends Object implements RequestFrame
Ancient versions of Kafka implemented SASL/GSSAPI by sending the token on the wire as length prefixed bytes (no Kafka protocol header). This frame represents those kinds of request.
See Also:
  • "org.apache.kafka.common.security.authenticator.SaslServerAuthenticator#handleKafkaRequest()"

  • Constructor Details

    • BareSaslRequest

      public BareSaslRequest(byte[] bytes, boolean decodeResponse)

  • Method Details

    • estimateEncodedSize

      public int estimateEncodedSize()
      Description copied from interface: Frame
      Estimate the expected encoded size in bytes of this Frame.
      In particular, written data by Frame.encode(ByteBufAccessor) should be the same as reported by this method.
      Specified by:
      estimateEncodedSize in interface Frame

    • encode

      public void encode(ByteBufAccessor out)
      Description copied from interface: Frame
      Write the frame, including the size prefix, to the given buffer
      Specified by:
      encode in interface Frame
      Parameters:
      out - The output buffer

    • correlationId

      public int correlationId()
      Description copied from interface: Frame
      The correlation id.
      Specified by:
      correlationId in interface Frame
      Returns:
      The correlation id.

    • apiKeyId

      public short apiKeyId()
      Description copied from interface: Frame
      Api key id of this frame.
      Specified by:
      apiKeyId in interface Frame

    • apiVersion

      public short apiVersion()
      Description copied from interface: Frame
      Api version of this frame.
      Specified by:
      apiVersion in interface Frame

    • isDecoded

      public boolean isDecoded()
      Description copied from interface: Frame
      true if this frame is decoded, false otherwise
      Specified by:
      isDecoded in interface Frame

    • decodeResponse

      public boolean decodeResponse()
      Description copied from interface: RequestFrame
      Whether the response to this request should be decoded.
      Specified by:
      decodeResponse in interface RequestFrame
      Returns:
      Whether the response to this request should be decoded.

    • bytes

      public byte[] bytes()