4단계: Amazon MSK 클러스터에서 주제 생성

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

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

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

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

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

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

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

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

sudo yum -y install java-11

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

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

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

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

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/v2.3.0/aws-msk-iam-auth-2.3.0-all.jar

이 명령을 사용하여 최신 버전의를 다운로드할 수도 있습니다aws-msk-iam-auth-*-all.jar.

kafka_2.13-{YOUR MSK VERSION}/config 디렉터리로 이동합니다. 다음 속성 설정을 복사하여 새 파일에 붙여넣습니다. 파일 이름을 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

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

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

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

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

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

다음 명령을 실행하여 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. 메시지가 표시됩니다.