Skip to main content

Target Connectors

Pipeline Creation / Connectors / Target

Target Connectors

Target connectors consume Kafka topics created by source connectors and write records to databases or storage systems. Relational targets usually use a JDBC sink connector.

Target Workflow

Target configuration starts from topic selection. The source topic name normally follows:

<source-topic-prefix>.<schema>.<table>

The target connector maps those topics to target tables, applies optional transforms, and writes records using connector-specific insert, update, and delete semantics.

Topic selectionSelect source topics or use a regular expression when the target should consume a group of replicated tables.
ConnectionUse Database Store where possible so credentials are validated and reusable.
Write modeChoose insert/upsert/delete behavior according to the target model.
TransformsUse SMTs to unwrap Debezium events or adapt field names before the record reaches the target.

Reference Pages