4단계: 주제 생성 - Amazon Managed Streaming for Apache Kafka

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

4단계: 주제 생성

Amazon MSK 사용 시작하기 단계에서는 클라이언트 머신에 Apache Kafka 클라이언트 라이브러리 및 도구를 설치한 다음 주제를 생성합니다.

주의

이 자습서에서 사용된 Apache Kafka 버전 번호는 예제일 뿐입니다. MSK 클러스터 버전과 동일한 버전의 클라이언트를 사용하는 것을 권장합니다. 이전 클라이언트 버전에는 특정 기능 및 중요한 버그 수정이 누락되었을 수 있습니다.

MSK 클러스터의 버전을 찾으려면 다음을 수행합니다.

  1. https://eu-west-2.console.aws.amazon.com/msk/으로 이동합니다.

  2. MSK 클러스터를 선택합니다.

  3. 클러스터에서 사용되는 Apache Kafka 버전을 확인합니다.

  4. 자습서에서 Amazon MSK 버전 번호의 인스턴스를 3단계에서 얻은 버전으로 변경합니다.

클라이언트 머신에 주제를 생성하려면

  1. https://console.aws.amazon.com/ec2/에서 Amazon EC2 콘솔을 엽니다.

  2. 탐색 창에서 인스턴스를 선택합니다. 그런 다음 3단계: 클라이언트 머신 생성에서 생성한 클라이언트 머신 이름 옆의 확인란을 선택합니다.

  3. 작업을 선택하고 연결을 선택합니다. 콘솔의 지침을 따라 클라이언트 머신에 연결합니다.

  4. 다음 명령을 실행하여 클라이언트 머신에 Java를 설치합니다.

    sudo yum -y install java-11

  5. Apache Kafka를 다운로드하려면 다음 명령을 실행합니다.

    wget https://archive.apache.org/dist/kafka/{YOUR MSK VERSION}/kafka_2.13-{YOUR MSK VERSION}.tgz
    참고

    이 명령에 사용된 사이트 이외의 미러 사이트를 사용하려면 Apache 웹사이트에서 다른 것을 선택할 수 있습니다.

  6. 이전 단계에 TAR 파일을 다운로드한 디렉토리에서 다음 명령을 실행합니다.

    tar -xzf kafka_2.13-{YOUR MSK VERSION}.tgz

  7. kafka_2.13-{YOUR MSK VERSION}/libs 디렉터리로 이동하고 다음 명령을 실행하여 Amazon MSK IAM JAR 파일을 다운로드합니다. Amazon MSK IAM JAR을 사용하면 클라이언트 머신이 클러스터에 액세스할 수 있습니다.

    wget https://github.com/aws/aws-msk-iam-auth/releases/download/v1.1.1/aws-msk-iam-auth-1.1.1-all.jar

  8. kafka_2.13-{YOUR MSK VERSION}/bin 디렉터리로 이동합니다. 다음 속성 설정을 복사하여 새 파일에 붙여넣습니다. 파일 이름을 client.properties로 지정하고 저장합니다.

    security.protocol=SASL_SSL
sasl.mechanism=AWS_MSK_IAM
sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required;
sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler

  9. https://console.aws.amazon.com/msk/에서 Amazon MSK 콘솔을 엽니다.

  10. 클러스터 상태가 활성이 될 때까지 기다립니다. 몇 분 정도 걸릴 수 있습니다. 상태가 활성이 되면 클러스터 이름을 선택합니다. 클러스터 요약이 포함된 페이지로 이동합니다.

  11. 클라이언트 정보 보기를 선택합니다.

  12. 프라이빗 엔드포인트에 대한 연결 문자열을 복사합니다.

    각 브로커에 대해 3개의 엔드포인트가 제공됩니다. 다음 단계에서는 브로커 엔드포인트가 하나만 필요합니다.

  13. 다음 명령을 실행하여 이전 단계에서 얻은 브로커 엔드포인트 중 하나로 BootstrapServerString대체합니다.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server BootstrapServerString --command-config client.properties --replication-factor 3 --partitions 1 --topic MSKTutorialTopic

    명령이 성공하면 Created topic MSKTutorialTopic. 메시지가 표시됩니다.

다음 단계

5단계: 데이터 생산 및 소비