Connect CDC SQData

Example 1

Simple JSON formatted Kafka where the * (asterisk) specifies that every source object name (i.e. table name) will become the Topic name.

REPLICATE

  DB2 cdc://<host_name>:<sqdaemon_port>/<publisher_name>/<subscription_name>

  TO JSON kafka:///*/key

;

 

Example 2

Simple JSON formatted Kafka where every source object name (i.e. table name) is written to a single Topic and all JSON objects are made AVRO compatible using the OPTIONS statement.

REPLICATE

  DB2 cdc://<host_name>:<sqdaemon_port>/<publisher_name>/<subscription_name>

  TO JSON kafka:///<topic_name>/key

;

 

OPTIONS

AVRO COMPATIBLE NAMES,

;

 

Example 3

Simple JSON formatted Kafka where every source object name (i.e. table name) is written to a specified Topic with a common prefix and suffix.

REPLICATE

  DB2 cdc://<host_name>:<sqdaemon_port>/<publisher_name>/<subscription_name>

  TO JSON kafka:///<prefix>_*_<suffix>/key

;