Tombstone Records

[stariq2]

It's a great connector but I couldn't get deletion work as a tombstone record. Any recommendations?

[ghost]

It's a great connector but I couldn't get deletion work as a tombstone record. Any recommendations?

have you solve problem?

[erdemcer]

Hi, This connector can capture deletion of records and this Kafka messages can be used to populate on target system. Could you please give some detail information what you expect ? Thanks

[ghost]

just like debezium.

when delete event is emitted by database debezium emit two messages: a delete message and a tombstone message that as a signal to kafka compaction process.

i have made a simple modify when operation equal 'delete' records will extra add tombstone message in oraclesourcetask class.

records.add( new SourceRecord(sourcePartition(), sourceOffset(scn, commitScn, rowId), topic,keySchema,Key, null, null));