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() |
int |
readInt() |
long |
readLong() |
short |
readShort() |
int |
readUnsignedVarint() |
void |
writeByte(byte val) |
void |
writeByteArray(byte[] arr) |
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 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 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 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 writeUnsignedVarint(int i)
writeUnsignedVarint
in interface org.apache.kafka.common.protocol.Writable