Apache Kafka 연결

AWS MSK 클러스터를 구성합니다.

AWS MSK 클러스터를 구성하여 Atlas 프로젝트에서 오는 연결을 수락해야 합니다.

1. 계정 세부 정보 가져오기 엔드포인트를 사용하여 AWS Principal ID를 조회합니다. AWS MSK 클러스터 정책에 이 값이 필요합니다.

2. AWS 관리 콘솔에 로그인하고 AWS MSK 콘솔로 이동합니다. 연결하려는 클러스터에서 multi-VPC connectivity가 활성화되어 있는지 확인합니다.

3. Properties, Security Settings 및 Edit cluster policy 를 클릭합니다.

   이전에 검색한 주체 ID의 전체 ARN 양식을 Statement.Principal.Aws.[] 값으로 제공하고 정책이 다음 형식을 취하는지 확인합니다.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Effect": "Allow",
               "Principal": {
                   "AWS": [
                       "arn:aws:iam:123456789012:root"
                   ]
               },
               "Action": [
                   "kafka:CreateVpcConnection",
                   "kafka:GetBootstrapBrokers",
                   "kafka:DescribeCluster",
                   "kafka:DescribeClusterV2"
               ],
               "Resource": "arn:aws:kafka:us-east-1:123456789012:cluster/testing/de8982fa-8222-4e87-8b20-9bf3cdfa1521-2"
           }
       ]
   }

cloud 제공자 에게 연결을 요청합니다.

Atlas 관리 API Atlas Stream Processing 위해 구성된 Private Link 연결을 요청하기 위한 엔드포인트를 제공합니다.

1개의 비공개 링크 만들기

atlas streams privateLinks create [options]

AWS MSK 비공개 링크 연결의 경우 다음 키-값 쌍을 설정해야 합니다.

AWS MSK 클러스터의 네트워킹 세부 정보에서 ARN을 찾을 수 있습니다.

다음 예시 명령은 AWS MSK 클러스터에 대한 연결 요청을 하고 일반적인 응답을 보여줍니다.

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": "msk",
  "provider": "AWS",
  "arn": "1235711"}'

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

요청 을 보낸 후 응답 본문의 _id 필드 값을 확인합니다. 이 정보는 이후 단계에서 필요합니다.

Atlas 측 연결을 생성합니다.

중요: 이 예시 SASL_SSL을 사용하여 보안된 연결을 추가하는 방법을 보여 줍니다. 상호 SSL를 사용하여 연결을 보호할 수도 있습니다.

SSL 인증 위해 이 API 에 지원되는 필드에 대한 자세한 내용은 Atlas 관리자 API 설명서를 참조하세요.

다음 키-값 쌍이 있는 연결을 추가합니다.

필요에 따라 다른 모든 값을 설정합니다.

다음 예시 명령은 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": "msk_demo",
  "bootstrapServers": "slr-ntgrbn.sample.us-east-1.amazonaws.com:9092",
  "security": {
    "protocol": "SASL_SSL"
  },
  "authentication": {
    "mechanism": "PLAIN",
    "password": "scramSecretDemo",
    "username": "scramUserDemo"
  },
  "type": "Kafka",
  "networking": {
    "access": {
    "type": "PRIVATE_LINK",
    "connectionId": "38972b0cbe9c2aa40a30a246"
    }
  }
}'

AtlasGo Atlas 에서 프로젝트 의 Network Access 페이지로 고 (Go) 합니다.

경고: 탐색 기능 개선 작업 진행 중

현재 새롭게 개선된 탐색 환경을 배포하고 있습니다. 다음 단계가 Atlas UI에서 보이는 것과 일치하지 않으면 미리 보기 문서를 참조하세요.

1. 아직 표시되지 않은 경우 탐색 표시줄의 Organizations 메뉴에서 프로젝트가 포함된 조직을 선택합니다.

2. 아직 표시되지 않은 경우 내비게이션 바의 Projects 메뉴에서 프로젝트를 선택합니다.

3. 사이드바에서 Security 제목 아래의 Network Access를 클릭합니다.

   네트워크 액세스 페이지가 표시됩니다.

Atlas Stream Processing의 비공개 엔드포인트 인터페이스로 이동합니다.

1. Private Endpoint 탭을 클릭합니다.

2. Atlas Stream Processing 탭을 클릭합니다.

3. Create endpoint를 클릭합니다.

클라우드 공급자와 벤더를 선택합니다.

1. Cloud Provider을 AWS로 설정합니다.

2. Vendor을 MSK로 설정합니다.

3. Next, enter service details를 클릭합니다.

AWS MSK 클러스터 ARN.을 제공하세요

Next, generate endpoint ID를 클릭합니다.