Package io.kroxylicious.proxy.frame

Class OpaqueRequestFrame

java.lang.Object

io.kroxylicious.proxy.frame.OpaqueFrame

io.kroxylicious.proxy.frame.OpaqueRequestFrame

All Implemented Interfaces:

Frame, RequestFrame

public class OpaqueRequestFrame
extends OpaqueFrame
implements RequestFrame

Used to represent Kafka requests that the proxy does not need to decode.

Field Summary

Fields inherited from class io.kroxylicious.proxy.frame.OpaqueFrame

buf, correlationId, length

Fields inherited from interface io.kroxylicious.proxy.frame.Frame

FRAME_SIZE_LENGTH

Constructor Summary

Constructors

Constructor	Description
OpaqueRequestFrame(io.netty.buffer.ByteBuf buf, short apiKeyId, short apiVersion, int correlationId, boolean decodeResponse, int length, boolean hasResponse)	Creates an opaque request.

Method Summary

Modifier and Type	Method	Description
boolean	decodeResponse()	Whether the response to this request should be decoded.
boolean	hasResponse()	Whether the Kafka Client expects a response to this request
String	toString()

Methods inherited from class io.kroxylicious.proxy.frame.OpaqueFrame

apiKeyId, apiVersion, buf, correlationId, encode, estimateEncodedSize, isDecoded, releaseBuffer

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.kroxylicious.proxy.frame.Frame

apiKeyId, apiVersion, correlationId, encode, estimateEncodedSize, isDecoded

Constructor Details

OpaqueRequestFrame

public OpaqueRequestFrame(io.netty.buffer.ByteBuf buf,
 short apiKeyId,
 short apiVersion,
 int correlationId,
 boolean decodeResponse,
 int length,
 boolean hasResponse)

Creates an opaque request.

Parameters:

buf - The message buffer (excluding the frame size)

apiKeyId - api key

apiVersion - api version

correlationId - correlation id

decodeResponse - whether the response will be decoded

length - length of the request

hasResponse - true if the request expects a response

Method Details

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.

hasResponse

public boolean hasResponse()

Description copied from interface: RequestFrame

Whether the Kafka Client expects a response to this request

Specified by:

hasResponse in interface RequestFrame

Returns:

Whether the Kafka Client expects a response to this request

toString

public String toString()

Overrides:

toString in class OpaqueFrame