- 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
;
- 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,
;
- 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