com.ververica.cdc.debezium.internal

Class DebeziumOffset

java.lang.Object

com.ververica.cdc.debezium.internal.DebeziumOffset

All Implemented Interfaces:

Serializable

@Internal
public class DebeziumOffset
extends Object
implements Serializable

The state that the Flink Debezium Consumer holds for each instance.

This class describes the most basic state that Debezium used for recovering based on Kafka Connect mechanism. It includes a sourcePartition and sourceOffset.

The sourcePartition represents a single input sourcePartition that the record came from (e.g. a filename, table name, or topic-partition). The sourceOffset represents a position in that sourcePartition which can be used to resume consumption of data.

These values can have arbitrary structure and should be represented using org.apache.kafka.connect.data objects (or primitive values). For example, a database connector might specify the sourcePartition as a record containing { "db": "database_name", "table": "table_name"} and the sourceOffset as a Long containing the timestamp of the row.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
Map<String,?>	sourceOffset
Map<String,?>	sourcePartition

Constructor Summary

Constructors

Constructor and Description
DebeziumOffset()

Method Summary

Modifier and Type	Method and Description
void	setSourceOffset(Map<String,?> sourceOffset)
void	setSourcePartition(Map<String,?> sourcePartition)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

sourcePartition

public Map<String,?> sourcePartition

sourceOffset

public Map<String,?> sourceOffset

Constructor Detail

DebeziumOffset

public DebeziumOffset()

Method Detail

setSourcePartition

public void setSourcePartition(Map<String,?> sourcePartition)

setSourceOffset

public void setSourceOffset(Map<String,?> sourceOffset)

toString

public String toString()

Overrides:

toString in class Object