public static ElasticPartitionMeta decode(ByteBuffer buf) {
        String metaStr = StandardCharsets.UTF_8.decode(buf).toString();
        try {
            return READER.readValue(metaStr);
        } catch (JsonProcessingException e) {
            throw new IllegalArgumentException(e);
        }
    }
The offset of the last cleaned record.
core/src/main/scala/kafka/log/streamaspect/ElasticPartitionMeta.java