CREATE CONNECTOR¶
Synopsis¶
CREATE SOURCE | SINK CONNECTOR 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.
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');
Last update: 2020-03-19