Package org.apache.flink.cdc.debezium.internal

Class DebeziumChangeConsumer

java.lang.Object

org.apache.flink.cdc.debezium.internal.DebeziumChangeConsumer

All Implemented Interfaces:

io.debezium.engine.DebeziumEngine.ChangeConsumer<io.debezium.engine.ChangeEvent<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord>>

@Internal
public class DebeziumChangeConsumer
extends Object
implements io.debezium.engine.DebeziumEngine.ChangeConsumer<io.debezium.engine.ChangeEvent<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord>>

Consume debezium change events.

Field Summary

Fields

Modifier and Type	Field	Description
static String	LAST_COMMIT_LSN_KEY
static String	LAST_COMPLETELY_PROCESSED_LSN_KEY

Constructor Summary

Constructors

Constructor	Description
DebeziumChangeConsumer(Handover handover)

Method Summary

Modifier and Type	Method	Description
void	commitOffset(DebeziumOffset offset)
void	handleBatch(List<io.debezium.engine.ChangeEvent<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord>> events, io.debezium.engine.DebeziumEngine.RecordCommitter<io.debezium.engine.ChangeEvent<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord>> recordCommitter)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.engine.DebeziumEngine.ChangeConsumer

supportsTombstoneEvents

Field Detail

LAST_COMPLETELY_PROCESSED_LSN_KEY

public static final String LAST_COMPLETELY_PROCESSED_LSN_KEY

See Also:

Constant Field Values

LAST_COMMIT_LSN_KEY

public static final String LAST_COMMIT_LSN_KEY

See Also:

Constant Field Values

Constructor Detail

DebeziumChangeConsumer

public DebeziumChangeConsumer(Handover handover)

Method Detail

handleBatch

public void handleBatch(List<io.debezium.engine.ChangeEvent<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord>> events,
                        io.debezium.engine.DebeziumEngine.RecordCommitter<io.debezium.engine.ChangeEvent<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord>> recordCommitter)

Specified by:

handleBatch in interface io.debezium.engine.DebeziumEngine.ChangeConsumer<io.debezium.engine.ChangeEvent<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord>>

commitOffset

public void commitOffset(DebeziumOffset offset)
                  throws InterruptedException

Throws:

InterruptedException