管理连接注册表

AtlasGoStream Processing在Atlas中，Go项目的 页面。

1. 如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含项目的组织。

2. 如果尚未显示，请从导航栏的 Projects 菜单中选择您的项目。

3. 在侧边栏中，单击 Services 标题下的 Stream Processing。

   此时将显示 Stream Processing 页面。

转到 Connection Registry（快速入门）页面。

1. 找到包含要查看的连接注册表的流处理实例的概览面板。

2. 单击 Configure（连接）。

3. 选择 Connection Registry 标签页。

Atlas Stream Processing 显示您实例连接注册表中可用的所有连接。

AtlasGoStream Processing在Atlas中，Go项目的 页面。

1. 如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含项目的组织。

2. 如果尚未显示，请从导航栏的 Projects 菜单中选择您的项目。

3. 在侧边栏中，单击 Services 标题下的 Stream Processing。

   此时将显示 Stream Processing 页面。

转到 Connection Registry（搜索测试器）。

找到包含要修改的连接注册表的流处理实例的概览面板，然后单击右上角的 Configure。

选择 Connection Registry（连接注册表）标签页。

修改连接。

1. 对于您要在表中修改的连接，请单击 Actions 列中的铅笔图标。

   仅当流处理器当前未使用连接时，才能编辑连接。如果要编辑正在使用的连接，请先停止使用该连接的所有流处理器。

2. 修改您想要修改的字段。

3. 单击 Save changes（连接）。

AtlasGoStream Processing在Atlas中，Go项目的 页面。

1. 如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含项目的组织。

2. 如果尚未显示，请从导航栏的 Projects 菜单中选择您的项目。

3. 在侧边栏中，单击 Services 标题下的 Stream Processing。

   此时将显示 Stream Processing 页面。

转到 Connection Registry（搜索测试器）。

1. 找到包含要修改的连接注册表的流处理实例的概述面板

2. 单击右上角的 Configure。

3. 选择 Connection Registry 标签页。

删除该连接。

1. 对于要在表中修改的连接，请单击该条目的 Actions 列中的垃圾桶图标。

2. 出现提示时，单击 Delete。

配置 Confluence集群。

您必须配置 Confluence集群以接受来自Atlas项目的传入连接。

1. 调用返回群组和地区的Atlas Administration API端点的帐户ID和VPC ID 。请记下awsAccountId 的值，您将在后续步骤中用到它。

2. 在您的 Confluence 帐户中，导航到要连接的集群。在集群网络界面中，导航到集群网络详细信息。

3. 添加专用链接访问权限

对于 Confluence专用集群，请提供您选择的名称。对于 AWS 帐号，提供您之前记下的awsAccountId 字段的值。

请求连接到您的云提供商。

Atlas Administration API提供一个端点，用于请求为Atlas Stream Processing配置的 Private Link 连接。

创建一个私有链接

对于 AWS Private Link 连接，您必须设立以下键值对：

您可以在 Confluence 集群的网络详细信息中找到这些值。

以下示例命令请求连接到 Confluence集群并说明了典型的响应：

curl --location 'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/privateLinkConnections' \
--digest \
--user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \
--header 'Content-Type: application/json' \
--header 'Accept: application/vnd.atlas.2023-02-01+json' \
--data '{ "vendor": "Confluent", "provider": "AWS",
  "region": "us_east_1", "serviceEndpointId":
  "com.amazonaws.vpce.us-east-1.vpce-svc-93da685022ee702a9",
  "dnsDomain": "sample.us-east-1.aws.confluent.cloud",
  "dnsSubDomain: [
    "use1-az1.sample.us-east-1.aws.confluent.cloud",
    "use1-az2.sample.us-east-1.aws.confluent.cloud",
    "use1-az4.sample.us-east-1.aws.confluent.cloud"
  ]
}'

{"_id":"6aa12e7ccd660d4b2380b1c1","dnsDomain":"sample.us-east-1.aws.confluent.cloud.","vendor":"Confluent","provider":"AWS","region":"us_east_1","serviceEndpointId":"com.amazonaws.vpce.us-east-1.vpce-svc-93da685022ee702a9"}

发送请求后，请记下响应正文中 _id字段的值。您将在后续步骤中用到它。

向 Confluence 提供接口端点ID 。

调用“返回所有专用链接连接”端点。请注意 interfaceEndpointId 的值。

在您的 Confluence 帐户中，导航到要连接的集群。在集群网络界面中，导航到集群网络详细信息。导航到访问权限点界面，然后添加新的访问权限点。当 Confluent 提示您输入接口端点时，请提供您之前记下的 interfaceEndpointId 值。

创建 Atlas 端连接。

添加具有以下键值对的连接：

根据需要设置所有其他值。

以下示例命令在Atlas中创建Apache Kafka连接：

curl --location 'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/spinstance/connections' \
--digest \
--user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \
--header 'Content-Type: application/json' \
--header 'Accept: application/vnd.atlas.2023-02-01+json' \
--data '{
  "name": "confluent_demo",
  "bootstrapServers": "slr-ntgrbn.sample.us-east-1.aws.confluent.cloud:9092",
  "security": {
    "protocol": "SASL_SSL"
  },
  "authentication": {
    "mechanism": "PLAIN",
    "password": "apiSecretDemo",
    "username": "apiUserDemo"
  },
  "type": "Kafka",
  "networking": {
    "access": {
    "type": "PRIVATE_LINK",
    "connectionId": "38972b0cbe9c2aa40a30a246"
    }
  }
}'

请求连接到您的云提供商。

Atlas Administration API提供一个端点，用于请求为Atlas Stream Processing配置的 Private Link 连接。

创建一个私有链接

对于Azure Private Link连接，必须设立以下键值对：

以下示例命令请求连接到Azure事件中心并说明了典型的响应：

curl --location 'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/privateLinkConnections' \
--digest \
--user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \
--header 'Content-Type: application/json' \
--header 'Accept: application/vnd.atlas.2023-02-01+json' \
--data '{ "provider": "AZURE", "region": "US_EAST_2", "serviceEndpointId": "/subscriptions/b82d6aa0-0b0a-ffa3-7c22-e167dc44f5b0/resourceGroups/asp/providers/Microsoft.EventHub/namespaces/sample", "dnsDomain": "sample.servicebus.windows.net" }'

{"_id":"6aa12e7ccd660d4b2380b1c1","dnsDomain":"sample.servicebus.windows.net","provider":"AZURE","region":"US_EAST_2","serviceEndpointId":"/subscriptions/b82d6aa0-0b0a-ffa3-7c22-e167dc44f5b0/resourceGroups/asp/providers/Microsoft.EventHub/namespaces/sample"}

发送请求后，请记下响应正文中 _id字段的值。您将在后续步骤中用到它。

在您的云提供商帐户中接受请求的连接。

对于到Azure的 Private Link 连接，请导航到事件中心网络页面并选择Private endpoint connections 标签页。在连接表中，确定新请求的连接并予以批准。

创建 Atlas 端连接。

添加具有以下键值对的连接：

根据需要设置所有其他值。

以下示例命令在Atlas中创建Apache Kafka连接：

curl --location 'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/spinstance/connections' \
--digest \
--user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \
--header 'Content-Type: application/json' \
--header 'Accept: application/vnd.atlas.2023-02-01+json' \
--data '{ "name": "eventhubpl33333", "bootstrapServers": "sample.servicebus.windows.net:9093", "security": { "protocol": "SASL_SSL" }, "authentication": { "mechanism": "PLAIN", "password": "Endpoint=sb://sample.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=Irlo3OoRkc27T3ZoGOlbhEOqXQRXzb12+Q2hNXm0lc=", "username": "$ConnectionString" }, "type": "Kafka", "networking": { "access": { "type": "PRIVATE_LINK", "connectionId": "38972b0cbe9c2aa40a30a246" } } }'