Class OffsetEncoder

java.lang.Object
io.confluent.parallelconsumer.offsets.OffsetEncoder
Direct Known Subclasses:
BitSetEncoder, ByteBufferEncoder, RunLengthEncoder

public abstract class OffsetEncoder extends Object
Base OffsetEncoder
  • Constructor Details

  • Method Details

    • getEncodingType

      protected abstract OffsetEncoding getEncodingType()
    • getEncodingTypeCompressed

      protected abstract OffsetEncoding getEncodingTypeCompressed()
    • getEncodedBytes

      protected abstract byte[] getEncodedBytes()