Starting Connectors
Creating Connect-Applications
-
Open the "Applications" page in the Self-Service portal
-
Click the New Application button. This window will open
-
Fill the required information in the form:
-
ID: The Application ID of your Connect-Application.
This is a string that uniquely identifies your Connect-Application.
The maximum length is 255. It can contain numbers, letters and dots.
We recommend using a fully qualified package/class name, which is sufficiently unique within the organization.
E.g.com.company.division.AppName
. -
Name: Full name of the Connect-Application.
This value is displayed when opening this Connect-Application’s page.
The maximum length is 50. Allowed characters are displayed in the UI. -
Short Name: A shorter name for the Connect-Application. This name is displayed in the applications list page, making it a little more important than the full name. The maximum length is 60. It can contain numbers, letters and underscores. It has to be unique within the company (tenant).
-
Owner: All members of the selected group will be authorized to edit this Connect-Application.
This dropdown lists all the groups you belong to. Choose an adequate group.
If no group is listed, ask a team member or platform-operator to add you to a group. -
Plugin Name: choose the plugin corresponding to the system you wish to integrate with Kafka
-
Visibility: Controls read access. Public applications are readable to the entire organisation.
Private applications are only visible to its owners. -
Description: A short summary describing the purpose of this application.
Limit of 200 characters.
-
-
Click the Add Application button in the bottom-right of the screen.
Upon creating the Connector-Application in the Self-Service portal, you will be directed to the application detail page.
Here you can "instantiate" this Connect-Application onto multiple environments.
Configuring and starting Connector-Applications
A Connector-Application needs 2 sets of configuration for every environment in which it’s deployed:
-
Security: The certificate and private key files used for authentication and authorization against the Kafka cluster.
-
Plugin Configuration: plugin-specific configuration, depending on the connector implementation (e.g. connectivity information for the integrated system).
|
Security configuration
The certificate and private key is used to authorize the Connector-Application against kafka when accessing the streams. At least one certificate and private key must be configured for every environment this application intends to use.
-
The certificate must be
X.509
formatted and contained within aPEM
file. Ideally, it should contain the whole certification chain.
The uploaded file must have one of the following file-extensions:.crt
,.cert
or.pem
. -
The private key must be
pkcs8
formatted and contained within aPEM
file.
The uploaded file must have the.pkcs8
file extension.
If your key material is currently in JKS format, you can extract the certificate and private key using a tool such as Keystore Explorer. You can also install it using multiple package managers (see repology), including brew. |
Considering you have both these files available, let’s configure the Connector-Application’s security:
-
From the drop-down list, select the environment for which you want to configure the certificate and private key.
-
Click on the Padlock button in the application box (hovering on the button will show the text 'Authorization'). The following window will show up:
-
Upload the Certificate file your connector will use in this environment.
The window will indicate the certificate was successfully uploaded, and request you follow-up with a private key: -
Upload the private-key file that matches the certificate.
The private key will not be displayed on the screen. You will only see whether it was successfully uploaded or not. The window will indicate the private key was successfully uploaded. -
Click Apply
Plugin configuration
-
Click on the Gear button in the application box (hovering on the button will show the text 'Configuration'). A window similar to this will show up:
-
If you are following a Connect-Plugin configuration guide, this is the step where you will provide the Connector configuration as instructed. Click the save button once you are done.
-
If your Connector-Application was successfully configured in the selected environment, you will see an extra box at the bottom of the application box and a status label at the top:
Requesting Stream Access
Your Connector-Application needs to be authorised to produce/consume a kafka stream before it can be started.
Follow the Requesting stream-access docs to grant it access.
Starting and stopping Connector-Applications
You can start the Connector by clicking the 'START' button. Within seconds, the status should change to 'RUNNING'.

If the status changed to FAILED
, then you can click View tasks
to open up a modal which shows you a stack trace which should give you more information.
Deleting A Connector Application
-
Stop all the Connector-Applications on all environments.
-
Follow the Deleting applications docs to remove the application.
Available Connector Application Actions
The following actions are available for Connector-Applications:
Connector action |
Effect |
|
start the connector application |
|
stop the connector application |
|
remove any existing active connector and its configuration (including offsets) |
The following actions are available for Connector-Tasks:
Task action |
Effect |
|
view the task(s) status and trace (in case the status is FAILED) |
|
restart a task in a FAILED state |