DebeziumEvent

class DebeziumEvent(event: ChangeEvent<String?, String?>)

Convenience wrapper around ChangeEvent.

Constructors

Link copied to clipboard
constructor(event: ChangeEvent<String?, String?>)

Properties

Link copied to clipboard

True if this is a Debezium heartbeat event, or the equivalent thereof. In any case, such events are only used for their position value and for triggering timeouts.

Link copied to clipboard

Debezium can output a tombstone event that has a value of null. This is an artifact of how it interacts with kafka. We want to ignore it. More on the tombstone: https://debezium.io/documentation/reference/stable/transformations/event-flattening.html

Link copied to clipboard
Link copied to clipboard
val sourceRecord: SourceRecord?

This SourceRecord object is the preferred way to obtain the current position.

Link copied to clipboard