Package io.kroxylicious.proxy.frame

Class DecodedRequestFrame<B extends org.apache.kafka.common.protocol.ApiMessage>

java.lang.Object

io.netty.util.AbstractReferenceCounted

io.kroxylicious.proxy.frame.DecodedFrame<org.apache.kafka.common.message.RequestHeaderData,B>

io.kroxylicious.proxy.frame.DecodedRequestFrame<B>

All Implemented Interfaces:

Frame, RequestFrame, io.netty.util.ReferenceCounted

Direct Known Subclasses:

InternalRequestFrame

public class DecodedRequestFrame<B extends org.apache.kafka.common.protocol.ApiMessage>
extends DecodedFrame<org.apache.kafka.common.message.RequestHeaderData,B>
implements RequestFrame

A decoded request frame.

Field Summary

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

apiVersion, body, correlationId, header

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

FRAME_SIZE_LENGTH

Constructor Summary

Constructors

Constructor	Description
DecodedRequestFrame(short apiVersion, int correlationId, boolean decodeResponse, org.apache.kafka.common.message.RequestHeaderData header, B body)

Method Summary

Modifier and Type	Method	Description
protected DecodedResponseFrame<? extends org.apache.kafka.common.protocol.ApiMessage>	createResponseFrame(org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.protocol.ApiMessage message)
boolean	decodeResponse()	Whether the response to this request should be decoded.
boolean	hasResponse()	Whether the Kafka Client expects a response to this request
short	headerVersion()
DecodedResponseFrame<? extends org.apache.kafka.common.protocol.ApiMessage>	responseFrame(org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.protocol.ApiMessage message)

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

add, apiKey, apiKeyId, apiVersion, body, correlationId, deallocate, encode, estimateEncodedSize, header, isDecoded, toString, touch, transferBuffersTo

Methods inherited from class io.netty.util.AbstractReferenceCounted

refCnt, release, release, retain, retain, setRefCnt, touch

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

DecodedRequestFrame

public DecodedRequestFrame(short apiVersion,
 int correlationId,
 boolean decodeResponse,
 org.apache.kafka.common.message.RequestHeaderData header,
 B body)

Method Details

headerVersion

public short headerVersion()

Specified by:

headerVersion in class DecodedFrame<org.apache.kafka.common.message.RequestHeaderData,B extends org.apache.kafka.common.protocol.ApiMessage>

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

responseFrame

public DecodedResponseFrame<? extends org.apache.kafka.common.protocol.ApiMessage> responseFrame(org.apache.kafka.common.message.ResponseHeaderData header,
 org.apache.kafka.common.protocol.ApiMessage message)

createResponseFrame

protected DecodedResponseFrame<? extends org.apache.kafka.common.protocol.ApiMessage> createResponseFrame(org.apache.kafka.common.message.ResponseHeaderData header,
 org.apache.kafka.common.protocol.ApiMessage message)