Package io.kroxylicious.proxy.internal.codec

Class KafkaRequestEncoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelOutboundHandlerAdapter

io.netty.handler.codec.MessageToByteEncoder<RequestFrame>

io.kroxylicious.proxy.internal.codec.KafkaRequestEncoder

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelOutboundHandler

public class KafkaRequestEncoder
extends io.netty.handler.codec.MessageToByteEncoder<RequestFrame>

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
static final int	API_KEY
static final int	API_VERSION
static final int	LENGTH

Constructor Summary

Constructors

Constructor	Description
KafkaRequestEncoder(CorrelationManager correlationManager, KafkaMessageListener listener)

Method Summary

Modifier and Type	Method	Description
protected io.netty.buffer.ByteBuf	allocateBuffer(io.netty.channel.ChannelHandlerContext ctx, RequestFrame msg, boolean preferDirect)	This has been overridden in order to use Frame.estimateEncodedSize() to pre-size correctly the holding buffer and save expensive enlarging to happen under the hood, during the encoding process.
protected void	encode(io.netty.channel.ChannelHandlerContext ctx, RequestFrame frame, io.netty.buffer.ByteBuf out)
protected org.slf4j.Logger	log()

Methods inherited from class io.netty.handler.codec.MessageToByteEncoder

acceptOutboundMessage, isPreferDirect, write

Methods inherited from class io.netty.channel.ChannelOutboundHandlerAdapter

bind, close, connect, deregister, disconnect, flush, read

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

exceptionCaught, handlerAdded, handlerRemoved

Field Details

LENGTH

public static final int LENGTH

See Also:

• Constant Field Values

API_KEY

public static final int API_KEY

See Also:

• Constant Field Values

API_VERSION

public static final int API_VERSION

See Also:

• Constant Field Values

Constructor Details

KafkaRequestEncoder

public KafkaRequestEncoder(CorrelationManager correlationManager,
 @Nullable
 KafkaMessageListener listener)

Method Details

log

protected org.slf4j.Logger log()

encode

protected void encode(io.netty.channel.ChannelHandlerContext ctx,
 RequestFrame frame,
 io.netty.buffer.ByteBuf out)
               throws Exception

Throws:

Exception

allocateBuffer

protected io.netty.buffer.ByteBuf allocateBuffer(io.netty.channel.ChannelHandlerContext ctx,
 RequestFrame msg,
 boolean preferDirect)
                                          throws Exception

This has been overridden in order to use Frame.estimateEncodedSize() to pre-size correctly the holding buffer and save expensive enlarging to happen under the hood, during the encoding process.

Overrides:

allocateBuffer in class io.netty.handler.codec.MessageToByteEncoder<F extends Frame>

Throws:

Exception