public class ByteBufAccessor extends 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() |
ByteBuffer |
readByteBuffer(int length) |
double |
readDouble() |
int |
readInt() |
long |
readLong() |
short |
readShort() |
int |
readUnsignedVarint() |
int |
readVarint() |
long |
readVarlong() |
void |
writeByte(byte val) |
void |
writeByteArray(byte[] arr) |
void |
writeByteBuffer(ByteBuffer buffer) |
void |
writeDouble(double val) |
void |
writeInt(int val) |
void |
writeLong(long val) |
void |
writeShort(short val) |
void |
writeUnsignedVarint(int i) |
void |
writeVarint(int i) |
void |
writeVarlong(long 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 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(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
public void writeVarint(int i)
writeVarint
in interface org.apache.kafka.common.protocol.Writable
public void writeVarlong(long i)
writeVarlong
in interface org.apache.kafka.common.protocol.Writable
public int readVarint()
readVarint
in interface org.apache.kafka.common.protocol.Readable
public long readVarlong()
readVarlong
in interface org.apache.kafka.common.protocol.Readable