public class SourceOffsets extends Object
Modifier and Type | Field and Description |
---|---|
static String |
CLUSTER_FIELD_KEY |
static String |
OFFSET_FIELD_KEY |
static org.apache.kafka.common.protocol.types.Schema |
RECORD_SCHEMA |
static String |
RECORDS_FIELD_KEY |
static org.apache.kafka.common.protocol.types.Schema |
SCHEMA |
Constructor and Description |
---|
SourceOffsets() |
SourceOffsets(Map<String,Long> sourceOffsets) |
Modifier and Type | Method and Description |
---|---|
void |
deserialize(byte[] data) |
ByteBuffer |
serialize() |
Map<String,Long> |
sourceOffsets() |
public static final String CLUSTER_FIELD_KEY
public static final String OFFSET_FIELD_KEY
public static final String RECORDS_FIELD_KEY
public static final org.apache.kafka.common.protocol.types.Schema RECORD_SCHEMA
public static final org.apache.kafka.common.protocol.types.Schema SCHEMA
public ByteBuffer serialize()
public void deserialize(byte[] data)