Using transformations

[Vladislav P]

Hi

Tell me about the transformations in the connectors.

We have a source connector that reads a table from ORACLE and 'message.key.columns'= "SCHEMA.TABLE:ID,LASTDATE".

The LASTDATE column is used in Postgre for partitioning by time. There are situations when the LASTDATE returns a null value. Now we are putting such records in the default table. But deleting by key (ID,LASTDATE) does not work for records with "LASTDATE=null", everything works for all other records.

The question is: can we change the value in the source connector, if it was null, to 0 or immediately to the current date.
Any transformer to use?

[Chris Cranford]

Hi - 

Of course you can; however if you are not flattening the source event from the source connector, you'll need to consider writing your own transform as the OOTB transfoms provided by Kafka do not yet support mapping to nested structures like Debezium's event format uses. 

-cc

Any transformer to use? --
You received this message because you are subscribed to the Google Groups "debezium" group.
To unsubscribe from this group and stop receiving emails from it, send an email to debezium+u...@googlegroups.com.
To view this discussion visit https://groups.google.com/d/msgid/debezium/f1061dff-c88c-4b67-8c76-6df0572ae60cn%40googlegroups.com.