public class ByteBufAccessor
extends java.lang.Object
implements org.apache.kafka.common.protocol.Readable, org.apache.kafka.common.protocol.Writable
Constructor and Description |
---|
ByteBufAccessor(io.netty.buffer.ByteBuf buf) |
Modifier and Type | Method and Description |
---|---|
void |
readArray(byte[] arr) |
byte |
readByte() |
java.nio.ByteBuffer |
readByteBuffer(int length) |
double |
readDouble() |
int |
readInt() |
long |
readLong() |
short |
readShort() |
int |
readUnsignedVarint() |
void |
writeByte(byte val) |
void |
writeByteArray(byte[] arr) |
void |
writeByteBuffer(java.nio.ByteBuffer buffer) |
void |
writeDouble(double val) |
void |
writeInt(int val) |
void |
writeLong(long val) |
void |
writeShort(short val) |
void |
writeUnsignedVarint(int i) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public byte readByte()
readByte
in interface org.apache.kafka.common.protocol.Readable
public short readShort()
readShort
in interface org.apache.kafka.common.protocol.Readable
public int readInt()
readInt
in interface org.apache.kafka.common.protocol.Readable
public double readDouble()
readDouble
in interface org.apache.kafka.common.protocol.Readable
public long readLong()
readLong
in interface org.apache.kafka.common.protocol.Readable
public void readArray(byte[] arr)
readArray
in interface org.apache.kafka.common.protocol.Readable
public int readUnsignedVarint()
readUnsignedVarint
in interface org.apache.kafka.common.protocol.Readable
public java.nio.ByteBuffer readByteBuffer(int length)
readByteBuffer
in interface org.apache.kafka.common.protocol.Readable
public void writeByte(byte val)
writeByte
in interface org.apache.kafka.common.protocol.Writable
public void writeShort(short val)
writeShort
in interface org.apache.kafka.common.protocol.Writable
public void writeInt(int val)
writeInt
in interface org.apache.kafka.common.protocol.Writable
public void writeDouble(double val)
writeDouble
in interface org.apache.kafka.common.protocol.Writable
public void writeLong(long val)
writeLong
in interface org.apache.kafka.common.protocol.Writable
public void writeByteArray(byte[] arr)
writeByteArray
in interface org.apache.kafka.common.protocol.Writable
public void writeByteBuffer(java.nio.ByteBuffer buffer)
writeByteBuffer
in interface org.apache.kafka.common.protocol.Writable
public void writeUnsignedVarint(int i)
writeUnsignedVarint
in interface org.apache.kafka.common.protocol.Writable