https://community.cloudera.com/t5/Archives-of-Support-Questions/Data-migration-to-Kafka-from-Oracle/m-p/143849#M48357 <P>You could use NiFi to read from the first, raw Kafka topic, enrich the messages with the appropriate values and perform other simple transformations, and then push to a second, final Kafka topic.</P> Thu, 08 Dec 2016 22:50:00 GMT slachterman 2016-12-08T22:50:00Z https://community.cloudera.com/t5/Archives-of-Support-Questions/Data-migration-to-Kafka-from-Oracle/m-p/143848#M48356 <P>I have a data migration from Oracle to Kafka via GoldenGate. I need to identify the records coming in from Oracle say with a source_identifier like say AA ...which is not present as field in Oracle tab.</P><P>How can I get this value of source identifier in Kafka json file</P><P>eg we have gg.handler.hdfs.format.insertOpKey=I</P><P>Similary is there any config that can be set to , put tag souce_identifier as AA in kafka.</P> Thu, 08 Dec 2016 20:34:19 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Data-migration-to-Kafka-from-Oracle/m-p/143848#M48356 joseph_c 2016-12-08T20:34:19Z https://community.cloudera.com/t5/Archives-of-Support-Questions/Data-migration-to-Kafka-from-Oracle/m-p/143849#M48357 <P>You could use NiFi to read from the first, raw Kafka topic, enrich the messages with the appropriate values and perform other simple transformations, and then push to a second, final Kafka topic.</P> Thu, 08 Dec 2016 22:50:00 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Data-migration-to-Kafka-from-Oracle/m-p/143849#M48357 slachterman 2016-12-08T22:50:00Z