@Internal public class DebeziumOffsetSerializer extends Object
DebeziumOffset.| Modifier and Type | Field and Description |
|---|---|
static DebeziumOffsetSerializer |
INSTANCE |
| Constructor and Description |
|---|
DebeziumOffsetSerializer() |
| Modifier and Type | Method and Description |
|---|---|
DebeziumOffset |
deserialize(byte[] bytes) |
byte[] |
serialize(DebeziumOffset debeziumOffset) |
public static final DebeziumOffsetSerializer INSTANCE
public byte[] serialize(DebeziumOffset debeziumOffset) throws IOException
IOExceptionpublic DebeziumOffset deserialize(byte[] bytes) throws IOException
IOExceptionCopyright © 2022 The Apache Software Foundation. All rights reserved.