Package io.kroxylicious.proxy.frame

Class DecodedResponseFrame<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.ResponseHeaderData,B>

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

All Implemented Interfaces:

Frame, ResponseFrame, io.netty.util.ReferenceCounted

Direct Known Subclasses:

InternalResponseFrame

public class DecodedResponseFrame<B extends org.apache.kafka.common.protocol.ApiMessage>
extends DecodedFrame<org.apache.kafka.common.message.ResponseHeaderData,B>
implements ResponseFrame

A decoded response 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
DecodedResponseFrame(short apiVersion, int correlationId, org.apache.kafka.common.message.ResponseHeaderData header, B body)

Method Summary

Modifier and Type	Method	Description
short	headerVersion()

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

DecodedResponseFrame

public DecodedResponseFrame(short apiVersion,
 int correlationId,
 org.apache.kafka.common.message.ResponseHeaderData header,
 B body)

Method Details

headerVersion

public short headerVersion()

Specified by:

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