클라이언트 머신 및 Apache Kafka 주제 생성 - Amazon Managed Streaming for Apache Kafka

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

클라이언트 머신 및 Apache Kafka 주제 생성

이 단계에서는 Apache Kafka 클라이언트 인스턴스로 사용할 Amazon EC2 인스턴스를 생성합니다. 그런 다음 해당 인스턴스를 사용하여 클러스터에 주제를 생성합니다.

클라이언트 머신을 만들려면

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

  2. 인스턴스 시작을 선택합니다.

  3. 클라이언트 머신의 이름을 입력합니다(예: mkc-tutorial-client).

  4. Amazon Linux 2 AMI(HVM) - 커널 5.10, SSD 볼륨 유형이 Amazon Machine Image(AMI) 유형으로 선택된 상태로 둡니다.

  5. t2.xlarge 인스턴스 유형을 선택합니다.

  6. 키 페어(로그인)에서 키 페어 생성을 선택합니다. 키 페어 이름에 mkc-tutorial-key-pair를 입력한 다음 키 페어 다운로드를 선택합니다. 또는 기존 키 페어를 사용할 수 있습니다.

  7. 인스턴스 시작을 선택합니다.

  8. 인스턴스 보기를 선택합니다. 그런 다음 보안 그룹 열에서 새 인스턴스와 연결된 보안 그룹을 선택합니다. 보안 그룹의 ID를 복사하여 나중에 사용할 수 있도록 저장합니다.

새로 생성된 클라이언트가 클러스터에 데이터를 전송할 수 있도록 허용하려면 다음을 수행합니다.

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

  2. 왼쪽 창의 보안에서 보안 그룹을 선택합니다. 보안 그룹 ID 열에서 클러스터의 보안 그룹을 찾습니다. MSK Connect에 필요한 리소스 설정에 클러스터를 생성할 때 이 보안 그룹의 ID를 저장했습니다. 행 왼쪽에 있는 상자를 선택하여 해당 보안 그룹을 선택합니다. 다른 보안 그룹이 동시에 선택되지 않았는지 확인합니다.

  3. 화면 하단에서 인바운드 규칙 탭을 선택합니다.

  4. 인바운드 규칙 편집을 선택합니다.

  5. 화면 왼쪽 하단에서 규칙 추가를 선택합니다.

  6. 새 규칙의 유형 열에서 모든 트래픽을 선택합니다. 소스 열의 오른쪽 필드에 클라이언트 컴퓨터의 보안 그룹 ID를 입력합니다. 클라이언트 머신을 생성한 후 저장한 보안 그룹 ID입니다.

  7. 규칙 저장을 선택합니다. 이제 MSK 클러스터가 이전 절차에서 생성한 클라이언트의 모든 트래픽을 허용합니다.

주제를 생성하려면

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

  2. 인스턴스 표에서 mkc-tutorial-client를 선택합니다.

  3. 화면 상단에서 연결을 선택한 다음 지침에 따라 인스턴스에 연결합니다.

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

    sudo yum install java-1.8.0

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

    wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz
    참고

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

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

    tar -xzf kafka_2.12-2.2.1.tgz

  7. kafka_2.12-2.2.1 디렉터리로 이동하십시오.

  8. https://console.aws.amazon.com/msk/home?region=us-east-1#/home/에서 Amazon MSK 콘솔을 엽니다.

  9. 왼쪽 창에서 클러스터를 선택한 다음 이름 mkc-tutorial-cluster를 선택합니다.

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

  11. 일반 텍스트 연결 문자열을 복사합니다.

  12. 완료를 선택합니다.

  13. 클라이언트 인스턴스(mkc-tutorial-client)에서 다음 명령을 실행하여 bootstrapServerString을 클러스터의 클라이언트 정보를 볼 때 저장한 값으로 변경합니다.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server bootstrapServerString --replication-factor 2 --partitions 1 --topic mkc-tutorial-topic

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

다음 단계

커넥터 생성