Creating and adding a new connector

Creating a New Connector

You can create the source connector either in the ksqlDB CLI or with kafka-ui via :

CREATE SOURCE CONNECTOR ConnectorName WITH (
...
);

Or via the following command for a Sink Connector:

CREATE SINK CONNECTOR ConnectorName WITH (
...
);

Adding a New Connector

To add a new connector, begin by including a module for it in the module’s build.sbt file. Then, create a class for your connector that extends either SourceConnector or SinkConnector, along with a class that extends SourceTask or SinkTask to define the tasks for the connector.

Additionally, thoroughly document the connector, detailing its functionality, usage instructions, and configurable properties.