Atlas Connections
On this page
Atlas Stream Processing supports both source and sink connections to Atlas clusters.
Add an Atlas Connection
To add an Atlas cluster connection to your stream processing instance:
To create one connection for the stream processing instance you specify using the Atlas CLI, run the following command:
atlas streams connections create [connectionName] [options]
To learn more about the command syntax and parameters, see the Atlas CLI documentation for atlas streams connections create.
When you create a stream processing instance using the Atlas CLI, you must provide a .json
configuration file to define the new connection's parameters. The format of this
file depends on the type of connection you define.
For an Atlas database connection, provide a configuration file with the following syntax:
{ "name": "<name>", "type": "Cluster", "clusterName": "<clusterName>" }
In Atlas, go to the Stream Processing page for your project.
Warning
Navigation Improvements In Progress
We're currently rolling out a new and improved navigation experience. If the following steps don't match your view in the Atlas UI, see the preview documentation.
If it's not already displayed, select the organization that contains your project from the Organizations menu in the navigation bar.
If it's not already displayed, select your project from the Projects menu in the navigation bar.
In the sidebar, click Stream Processing under the Services heading.
The Stream Processing page displays.
Add a new connection.
To create a new connection to an Atlas change stream:
Select an Atlas Database connection.
Provide a Connection Name. Each connection name must be unique within an stream processing instance. This is the name used to reference the connection in Atlas Stream Processing aggregations.
From the dropdown menu, select an Atlas Cluster. Atlas Stream Processing is only available on dedicated-tier clusters.
Click Add connection.
The Atlas Administration API provides an endpoint for adding a connection to a connection registry.