OCI 스트리밍에 접속

OCI Streaming에 대한 연결을 생성하여 OCI GoldenGate 데이터 복제 및 Stream Analytics를 통해 소스 또는 타겟으로 사용하는 방법을 알아보십시오.

시작하기 전에

OCI Streaming에 대한 연결을 생성하기 전에 다음을 확인합니다.

  • OCI GoldenGate가 소스 및 대상에 연결하는 방법을 검토합니다.
  • 암호 사용, 저장소 사용 및 암호 번들 읽기와 같은 보안 저장소 및 암호 액세스를 사용으로 설정하는 데 필요한 정책을 구성합니다. 자세한 내용은 최소 권장 정책을 참조하십시오.
  • 리소스 주체를 사용하여 OCI Streaming에 대한 액세스를 인증하는 경우 다음을 수행해야 합니다.
    1. 배치에 대한 동적 그룹을 생성합니다. 컴파트먼트 또는 테넌시의 단일 배치 또는 모든 배치에 권한을 부여하도록 선택할 수 있습니다. 동적 그룹을 정의하기 위해 일치 규칙 작성을 참조하십시오.
    2. 동적 그룹에 대한 필수 정책 추가
  • 스트림 풀 사용자 이름을 가져옵니다.
    1. Oracle Cloud 콘솔 탐색 메뉴에서 스트리밍, 스트림 풀 순으로 선택합니다.
    2. 스트림 풀 페이지에서 풀을 선택하여 세부정보를 봅니다.
    3. 스트림 풀 세부정보 페이지의 리소스에서 Kafka 접속 설정을 누릅니다.
    4. SASL 접속 문자열에 대한 사용자 이름을 복사합니다.

      주:

      Oracle Identity Cloud 서비스를 사용 중인 경우 사용자 이름에 OracleIdentityCloudService를 추가해야 합니다. 예: <tenancy-name>/OracleIdentityCloudService/<username>/<streampool-ocid>
    5. 권한 부여 토큰 생성:
      1. Oracle Cloud 콘솔 글로벌 헤더에서 프로파일을 누른 다음 사용자 설정을 선택합니다.
      2. 사용자 세부정보 페이지의 리소스에서 인증 토큰, 토큰 생성 순으로 누릅니다.
      3. 토큰 생성 대화상자에서 설명을 입력한 다음 토큰 생성을 누릅니다.
      4. 나중에 검색할 수 있는 보안 위치로 대화상자의 인증 토큰을 복사한 다음 닫기를 누릅니다.

스트림 접속의 사용자 이름과 비밀번호에 대해 스트림 풀 사용자 이름 및 인증 토큰이 입력됩니다.

소스 접속 생성

소스 OCI Streaming 연결을 생성하려면 다음을 수행합니다.
  1. OCI GoldenGate 개요 페이지에서 접속을 누릅니다.
    시작 섹션 아래에서 접속 생성을 누르고 3단계로 건너뛸 수도 있습니다.
  2. Connections 페이지에서 Create Connection을 누릅니다.
  3. Create Connection 페이지에서 다음과 같이 필드에 정보를 입력합니다.
    1. 이름에 연결 이름을 입력합니다.
    2. (선택 사항) 설명에 이 연결을 다른 연결과 구분하는 데 도움이 되는 설명을 입력합니다.
    3. 컴파트먼트의 경우 접속을 생성할 컴파트먼트를 선택합니다.
    4. 유형 드롭다운에서 OCI 스트리밍을 선택합니다.
    5. 스트림 풀 세부정보의 경우 다음을 선택할 수 있습니다.
      • 스트림 풀 선택
        1. 드롭다운에서 스트림 풀을 선택하거나 컴파트먼트 변경을 눌러 다른 컴파트먼트에서 하나를 선택합니다.
      • 스트림 풀 정보를 입력하여 스트림 풀 정보를 수동으로 입력합니다.
        1. 부트스트랩 서버의 HostPort를 입력합니다.

          주:

          전용 IP를 입력하면 OCI GoldenGate가 전용 IP를 ip-10-0-0-0.ociggsvc.oracle.vcn.com 형식으로 다시 씁니다.
    6. 사용자의 경우 스트림 풀 인증 및 액세스 방법을 선택합니다.
      • 사용자 이름 및 암호: 위의 필요 조건 단계에서 SASL 연결 설정에서 복사된 스트림 풀 사용자 이름을 입력합니다.
      • 리소스 주체 사용: 리소스 주체를 사용하여 다른 OCI 리소스에 액세스하도록 인증합니다.
    7. 데이터베이스 사용자 비밀번호 암호를 선택합니다. 다른 컴파트먼트에 있는 경우 드롭다운을 사용하여 컴파트먼트를 변경합니다.

      주:

      • 암호는 암호, 인증서, SSH 키 또는 OCI 서비스와 함께 사용하는 인증 토큰과 같은 인증서입니다. 암호를 만들려면 암호 만들기를 참조하십시오. 다음을 수행했는지 확인합니다.
        • 수동 암호 생성을 선택합니다.
        • 인증서를 비밀 내용에 붙여넣습니다.
      • 암호 암호를 사용하지 않으려면 이 양식 하단에 있는 고급 옵션 아래의 보안 섹션에서 저장소에 암호 사용을 선택 해제해야 합니다.
    8. 고급 옵션 표시를 확장합니다. 다음과 같은 옵션을 구성할 수 있습니다.
      • 보안
        • 이 접속에 비밀번호 암호를 사용하지 않으려는 저장소 암호 사용의 선택을 해제합니다. 선택되지 않은 경우:
          • 모든 암호화 키 관리를 Oracle에 맡기려면 Oracle 관리 암호화 키 사용을 선택합니다.
          • 고객 관리 암호화 키 사용을 선택하여 접속 인증서를 암호화하기 위해 OCI 저장소에 저장된 특정 암호화 키를 선택합니다.
      • 네트워크 접속
        • 공유 끝점 - 지정된 배치와 끝점을 공유합니다. 배치의 수신 IP에서 접속을 허용해야 합니다.
        • 전용 끝점 - VCN의 지정된 서브넷에 있는 전용 끝점을 통한 네트워크 트래픽용입니다. 이 접속의 수신 IP에서 접속을 허용해야 합니다.

          주:

          • 전용 연결이 7일 동안 할당되지 않은 상태로 유지되면 서비스가 이를 공유 연결로 변환합니다.
          • Oracle GoldenGate 연결에 대해 자세히 알아보십시오.
      • 설정

        OCI Streaming에서 캡처하려면 다음 역직렬화기 또는 변환기 중 하나를 사용하여 consumer.properties 파일을 생성한 다음 파일을 소비자 속성으로 끌어 놓습니다.

        • JSON deserializer에 대한 Kafka 소비자 속성:
          key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer
          value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer
        • JSON 변환기에 대한 Kafka 소비자 속성:
          key.converter=org.apache.kafka.connect.json.JsonConverter
          value.converter=org.apache.kafka.connect.json.JsonConverter
        • Avro 변환기를 위한 Kafka 소비자 속성:
          key.converter=io.confluent.connect.avro.AvroConverter
          value.converter=io.confluent.connect.avro.AvroConverter
      • 태그: 리소스를 구성할 태그를 추가합니다.
  4. 생성을 누릅니다.
연결이 생성되면 Connections(연결) 목록에 나타납니다. 복제에서 소스 또는 대상으로 사용할 접속을 배치에 지정해야 합니다.

대상 접속 생성

대상 OCI Streaming 연결을 생성하려면 다음을 수행합니다.
  1. OCI GoldenGate 개요 페이지에서 접속을 누릅니다.
    시작 섹션 아래에서 접속 생성을 누르고 3단계로 건너뛸 수도 있습니다.
  2. Connections 페이지에서 Create Connection을 누릅니다.
  3. Create Connection 페이지에서 다음과 같이 필드에 정보를 입력합니다.
    1. 이름에 연결 이름을 입력합니다.
    2. (선택 사항) 설명에 이 연결을 다른 연결과 구분하는 데 도움이 되는 설명을 입력합니다.
    3. 컴파트먼트의 경우 접속을 생성할 컴파트먼트를 선택합니다.
    4. 유형 드롭다운에서 OCI 스트리밍을 선택합니다.
    5. 스트림 풀 세부정보의 경우 다음을 선택할 수 있습니다.
      • 스트림 풀 선택
        1. 드롭다운에서 스트림 풀을 선택하거나 컴파트먼트 변경을 눌러 다른 컴파트먼트에서 하나를 선택합니다.
      • 스트림 풀 정보를 입력하여 스트림 풀 정보를 수동으로 입력합니다.
        1. 부트스트랩 서버의 HostPort를 입력합니다.

          주:

          전용 IP를 입력하면 OCI GoldenGate가 전용 IP를 ip-10-0-0-0.ociggsvc.oracle.vcn.com 형식으로 다시 씁니다.
    6. 사용자의 경우 스트림 풀 인증 및 액세스 방법을 선택합니다.
      • 사용자 이름 및 암호: 위의 필요 조건 단계에서 SASL 연결 설정에서 복사된 스트림 풀 사용자 이름을 입력합니다.
      • 리소스 주체 사용: 리소스 주체를 사용하여 다른 OCI 리소스에 액세스하도록 인증합니다.
    7. 데이터베이스 사용자 비밀번호 암호를 선택합니다. 다른 컴파트먼트에 있는 경우 드롭다운을 사용하여 컴파트먼트를 변경합니다.

      주:

      • 암호는 암호, 인증서, SSH 키 또는 OCI 서비스와 함께 사용하는 인증 토큰과 같은 인증서입니다. 암호를 만들려면 암호 만들기를 참조하십시오. 다음을 수행했는지 확인합니다.
        • 수동 암호 생성을 선택합니다.
        • 인증서를 비밀 내용에 붙여넣습니다.
      • 암호 암호를 사용하지 않으려면 이 양식 하단에 있는 고급 옵션 아래의 보안 섹션에서 저장소에 암호 사용을 선택 해제해야 합니다.
    8. 고급 옵션 표시를 확장합니다. 다음과 같은 옵션을 구성할 수 있습니다.
      • 보안
        • 이 접속에 비밀번호 암호를 사용하지 않으려는 저장소 암호 사용의 선택을 해제합니다. 선택되지 않은 경우:
          • 모든 암호화 키 관리를 Oracle에 맡기려면 Oracle 관리 암호화 키 사용을 선택합니다.
          • 고객 관리 암호화 키 사용을 선택하여 접속 인증서를 암호화하기 위해 OCI 저장소에 저장된 특정 암호화 키를 선택합니다.
      • 네트워크 접속
        • 공유 끝점 - 지정된 배치와 끝점을 공유합니다. 배치의 수신 IP에서 접속을 허용해야 합니다.
        • 전용 끝점 - VCN의 지정된 서브넷에 있는 전용 끝점을 통한 네트워크 트래픽용입니다. 이 접속의 수신 IP에서 접속을 허용해야 합니다.

          주:

          • 전용 연결이 7일 동안 할당되지 않은 상태로 유지되면 서비스가 이를 공유 연결로 변환합니다.
          • Oracle GoldenGate 연결에 대해 자세히 알아보십시오.
      • 설정

        Kafka 복제에서 Snappy 압축을 사용하려면 생산자 속성을 끌어 놓거나 선택하고 Using Compression OCI GoldenGate (Confluent) Kafka Replication에 설명된 대로 복제 설정을 변경합니다.

      • 태그: 리소스를 구성할 태그를 추가합니다.
  4. 생성을 누릅니다.
연결이 생성되면 Connections(연결) 목록에 나타납니다. 복제에서 소스 또는 대상으로 사용할 접속을 배치에 지정해야 합니다.