We are replicating DB2 (ZOS) data to Kafka and from kafka we use S3 connector to write data in S3.
we are using derived column to figure out type of operation done on row to identify Insert/update/delete.
it works for insert and update, it doesn't work for delete. instead of D we get keys and operation type - null as avro messages.
derived column-
%IF(&ENTTYP='PT' OR &ENTTYP='RR','I', %IF(&ENTTYP= 'UB', 'U', %IF(&ENTTYP= 'UP','U', %IF(&ENTTYP='DL','D','D'))))
Could you Please let us know how can we identify delete ?
our S3 connector is not working for delete now.
------------------------------
Abhishek Kumar
------------------------------
#DataIntegration#DataReplication