Package io.kroxylicious.proxy.internal.util

Class ByteBufOutputStream

java.lang.Object

java.io.OutputStream

org.apache.kafka.common.utils.ByteBufferOutputStream

io.kroxylicious.proxy.internal.util.ByteBufOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class ByteBufOutputStream
extends org.apache.kafka.common.utils.ByteBufferOutputStream

This class has been introduced as a work-around to allow using pooled ByteBuf instances that are allowed to grow on demand while used on MemoryRecordsBuilder to create records (using MemoryRecordsHelper factory methods).

Constructor Summary

Constructors

Constructor	Description
ByteBufOutputStream(io.netty.buffer.ByteBuf byteBuf)

Method Summary

Modifier and Type	Method	Description
ByteBuffer	buffer()
io.netty.buffer.ByteBuf	byteBuf()
void	ensureRemaining(int remainingBytesRequired)
int	initialCapacity()
int	limit()
int	position()
void	position(int position)
int	remaining()
void	write(byte[] bytes, int off, int len)
void	write(int b)
void	write(ByteBuffer sourceBuffer)

Methods inherited from class java.io.OutputStream

close, flush, nullOutputStream, write

Methods inherited from class java.lang.Object

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

Constructor Details

ByteBufOutputStream

public ByteBufOutputStream(io.netty.buffer.ByteBuf byteBuf)

Method Details

write

public void write(int b)

Overrides:

write in class org.apache.kafka.common.utils.ByteBufferOutputStream

write

public void write(byte[] bytes,
 int off,
 int len)

Overrides:

write in class org.apache.kafka.common.utils.ByteBufferOutputStream

write

public void write(ByteBuffer sourceBuffer)

Overrides:

write in class org.apache.kafka.common.utils.ByteBufferOutputStream

buffer

public ByteBuffer buffer()

Overrides:

buffer in class org.apache.kafka.common.utils.ByteBufferOutputStream

byteBuf

public io.netty.buffer.ByteBuf byteBuf()

position

public int position()

Overrides:

position in class org.apache.kafka.common.utils.ByteBufferOutputStream

remaining

public int remaining()

Overrides:

remaining in class org.apache.kafka.common.utils.ByteBufferOutputStream

limit

public int limit()

Overrides:

limit in class org.apache.kafka.common.utils.ByteBufferOutputStream

position

public void position(int position)

Overrides:

position in class org.apache.kafka.common.utils.ByteBufferOutputStream

initialCapacity

public int initialCapacity()

Overrides:

initialCapacity in class org.apache.kafka.common.utils.ByteBufferOutputStream

ensureRemaining

public void ensureRemaining(int remainingBytesRequired)

Overrides:

ensureRemaining in class org.apache.kafka.common.utils.ByteBufferOutputStream