Class EncodedOffsetPair
java.lang.Object
io.confluent.parallelconsumer.offsets.EncodedOffsetPair
- All Implemented Interfaces:
Comparable<EncodedOffsetPair>
- See Also:
-
unwrap(byte[])
-
Field Summary
Fields -
Method Summary
Modifier and TypeMethodDescriptionintgetData()getDecodedIncompletes(long baseOffset) byte[]Copies array out of the ByteBuffertoString()Used for printing out the comparative map of each encoder
-
Field Details
-
SIZE_COMPARATOR
-
-
Method Details
-
compareTo
- Specified by:
compareToin interfaceComparable<EncodedOffsetPair>
-
toString
Used for printing out the comparative map of each encoder -
readDataArrayForDebug
public byte[] readDataArrayForDebug()Copies array out of the ByteBuffer -
getDecodedString
-
getDecodedIncompletes
-
getEncoding
-
getData
-