Kafka AVRO confluent target - connect_cdc_sqdata - Latest

Prerequisites

• The url of the Confluent Repository to use must be present in the OPTIONS statement.
• Connect CDC (SQData) assumes that support for command line url (cURL) and the Confluent Schema Registry has been installed and configured somewhere in your environment for use by both Apply and Replicator Engines. The URL and port number of the Registry will be required in order to read and register schema information.
• The external library libcurl is required to support communication with the Confluent Schema Registry. Libcurl can be installed using distribution provided package if available or built from source which can be downloaded from https://curl.se/download.html.
• The Confluent Platform is available at https://www.confluent.io/download/.
• The MAPPINGS section, either static or dynamic, must be able to provide a 'subject', which is effectively a key to the Confluent Schema Registry, for each source object to be replicated. The Replicator will use the description of the source object provided by the Publisher to generate an appropriate schema, and will use the subject to determine the confluent topic id associated with the object, using the provided 'subject' name. If the schema is not registered, the Replicator will register a new one under the indicated 'subject'.
• The MAPPINGS section may also provide a ‘topic’ which will be used to name the Kafka topic for a specific source object name (i.e. table name). A given topic can be used for one or more object tables, even all of them. If only one topic is to be used, it can be encoded in the target url. If more than one topic is to be used, the target url must be a generic url, of nature Kafka, the substitution parameter "*" being replaced by the topic value for each Source object.

Simple AVRO Confluent formatted Kafka where every source object name (i.e. table name) is written to a specified Topic with a common prefix and suffix and using an AVRO schema managed by the Confluent Registry.

REPLICATE
  DB2 cdc://<host_name>:<sqdaemon_port>/<publisher_name>/<subscription_name>
  TO AVRO CONFLUENT kafka:///<prefix>_*_<suffix>/key
;
OPTIONS
CONFLUENT REPOSITORY 'http://<host_name>:<host_port>',
;