Apache Kafka 주제 생성 - Amazon Managed Streaming for Apache Kafka
주제 생성을 위한 환경 설정주제 생성 및 여기에 데이터 쓰기

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

Apache Kafka 주제 생성

이 단계에서는 이전에 생성한 클라이언트 머신을 사용하여 서버리스 클러스터에 주제를 생성합니다.

주제 생성을 위한 환경 설정

  • 주제를 생성하기 전에 AWS MSK IAM JAR 파일을 Kafka 설치의 libs/ 디렉터리에 다운로드했는지 확인합니다. 아직 수행하지 않은 경우 Kafka의 libs/ 디렉터리에서 다음 명령을 실행합니다.

    wget https://github.com/aws/aws-msk-iam-auth/releases/download/v2.3.0/aws-msk-iam-auth-2.3.0-all.jar

    이 JAR 파일은 MSK Serverless 클러스터를 사용한 IAM 인증에 필요합니다.

  • Kafka 명령을 실행할 때에 AWS MSK IAM JAR 파일이 classpath 포함되어 있는지 확인해야 할 수 있습니다. 이렇게 하려면 다음 중 한 가지를 수행합니다.

    • 다음 예제와 같이 Kafka 라이브러리를 포함하도록 CLASSPATH 환경 변수를 설정합니다.

      export CLASSPATH=<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar

    • 다음 예제classpath와 같이 명시적와 함께 전체 Java 명령을 사용하여 Kafka 명령을 실행합니다.

      java -cp "<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar" org.apache.kafka.tools.TopicCommand --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6

주제 생성 및 여기에 데이터 쓰기

  1. 다음 export 명령에서 my-endpoint를 클러스터를 생성한 후 저장한 부트스트랩 서버 문자열로 변경합니다. 그런 다음 클라이언트 머신의 kafka_2.12-2.8.1/bin 디렉터리로 이동하여 export 명령을 실행합니다.

    export BS=my-endpoint

  2. 다음 명령을 실행하여 msk-serverless-tutorial이라는 주제를 생성합니다.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6

다음 단계

MSK Serverless에서 데이터 생성 및 소비