Kafka CDC MESSAGE target - connect_cdc_sqdata - Latest

Prerequisite

• The static MAPPINGS section must provide a source DBD Name and an alias name for the IMSDBD', for each DBD to be replicated.

CDC MESSAGE formatted Kafka topics where every source object name (i.e. segment name) is written to a specified Topic specified for each DBD.

REPLICATE
  IMS cdc://<host_name>:<sqdaemon_port>/<publisher_name>/<subscription_name>
  TO CDC MESSAGE 'kafka://<host_name>:<host_port>/<topic>'
  WITH 1 WORKER
;

OPTIONS
AVRO COMPATIBLE NAMES,
STRIP TRAILING SPACES,
NAMESPACE '<name_space>'
;

MAPPINGS
  SOURCE '<imsdbd1>'
          SUBJECT '<imscdc-value>
          ALIAS '<alias_1>' ROOTKEYLEN <key_length_1>
  SOURCE '<imsdbd2>'
          SUBJECT '<imscdc-value>
          ALIAS '<alias_2>' ROOTKEYLEN <key_length_2>
;