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

# 클라이언트 머신 및 Apache Kafka 주제 생성
<a name="mkc-create-topic"></a>

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

**주제를 생성하려면**

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

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

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

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

   ```
   sudo yum install java-1.8.0
   ```

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

   ```
   wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz
   ```
**참고**  
이 명령에 사용된 사이트 이외의 미러 사이트를 사용하려면 [Apache](https://www.apache.org/dyn/closer.cgi?path=/kafka/1.1.1/kafka_2.11-1.1.1.tgz) 웹사이트에서 다른 것을 선택할 수 있습니다.

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

   ```
   tar -xzf kafka_2.12-2.2.1.tgz
   ```

1. **kafka\$12.12-2.2.1** 디렉터리로 이동하십시오.

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

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

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

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

1. **완료**를 선택합니다.

1. 클라이언트 인스턴스(`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.` 메시지가 표시됩니다.

**다음 단계**

[커넥터 생성](mkc-create-connector.md)