Package io.confluent.parallelconsumer.offsets

Class EncodedOffsetPair

java.lang.Object

io.confluent.parallelconsumer.offsets.EncodedOffsetPair

All Implemented Interfaces:

Comparable<EncodedOffsetPair>

public final class EncodedOffsetPair
extends Object
implements Comparable<EncodedOffsetPair>

See Also:

• unwrap(byte[])

Field Summary

Fields

Modifier and Type	Field	Description
static final Comparator<EncodedOffsetPair>	SIZE_COMPARATOR

Method Summary

Modifier and Type	Method	Description
int	compareTo(EncodedOffsetPair o)
ByteBuffer	getData()
OffsetMapCodecManager.HighestOffsetAndIncompletes	getDecodedIncompletes(long baseOffset)
String	getDecodedString()
OffsetEncoding	getEncoding()
byte[]	readDataArrayForDebug()	Copies array out of the ByteBuffer
String	toString()	Used for printing out the comparative map of each encoder

Methods inherited from class java.lang.Object

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

Field Details

SIZE_COMPARATOR

public static final Comparator<EncodedOffsetPair> SIZE_COMPARATOR

Method Details

compareTo

public int compareTo(EncodedOffsetPair o)

Specified by:

compareTo in interface Comparable<EncodedOffsetPair>

toString

public String toString()

Used for printing out the comparative map of each encoder

Overrides:

toString in class Object

readDataArrayForDebug

public byte[] readDataArrayForDebug()

Copies array out of the ByteBuffer

getDecodedString

public String getDecodedString()

getDecodedIncompletes

public OffsetMapCodecManager.HighestOffsetAndIncompletes getDecodedIncompletes(long baseOffset)

getEncoding

public OffsetEncoding getEncoding()

getData

public ByteBuffer getData()