Connect CDC SQData

While the Replicator Engine will receive source database schemas from the Capture/Publisher and automatically generate the required AVRO Schemas, it is necessary to identify the source tables that will be processed by the Replicator Engine in it's script.

 

Note, The Engines will automatically handle both Code page translation and Data Type transformation as well as provide for the handling of invalid source data when applicable.

 

Example

Unlike the Apply Engine example above, the Replicator Engine script requires only the Source Table Names and specification of the Topic and Subject whose content will contain values defined by the planners and architects of the organization's Confluent Schema Registry.  The examples used here are arbitrary but were selected based on the source Table Names, source application and schema source, in this example, the  EMPLOYEE and DEPARTMENT Tables, a Db2 "IVP_HR" Database and SQData respectively.

MAPPINGS

   SOURCE 'IVP_HR.EMPLOYEE'

          TOPIC IVP_HR_EMPLOYEE

          SUBJECT IVP_HR_EMPLOYEE-value;

           ALIAS 'EMPLOYEE'

  ,SOURCE 'IVP_HR.DEPARTMENT'

          TOPIC IVP_HR_DEPARTMENT

          SUBJECT IVP_HR_DEPARTMENT-value;

           ALIAS 'DEPARTMENT';