CREATE CONNECTOR statement in ksqlDB for Confluent Platform¶

Synopsis¶

CREATE SOURCE | SINK CONNECTOR [IF NOT EXISTS] connector_name WITH( property_name = expression [, ...]);

Description¶

Create a new connector in the Kafka Connect cluster with the configuration passed in the WITH clause. Some connectors have ksqlDB templates that simplify configuring them. For more information, see Natively Supported Connectors.

If the IF NOT EXISTS clause is present, the statement does not fail if a connector with the supplied name already exists

Note

CREATE CONNECTOR works only in interactive mode.

Example¶

CREATE SOURCE CONNECTOR `jdbc-connector` WITH(
    "connector.class"='io.confluent.connect.jdbc.JdbcSourceConnector',
    "connection.url"='jdbc:postgresql://localhost:5432/my.db',
    "mode"='bulk',
    "topic.prefix"='jdbc-',
    "table.whitelist"='users',
    "key"='username');

Note

See CREATE CONNECTOR in action: