本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

# 建立用戶端機器和 Apache Kafka 主題
<a name="mkc-create-topic"></a>

在此步驟中，您會建立 Amazon EC2 執行個體，以用作 Apache Kafka 用戶端執行個體。然後，您可使用此執行個體在叢集上建立主題。

**建立用戶端機器**

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) – Kernel 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. 選擇 **Edit inbound Rules** (編輯傳入規則)。

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. 開啟 Amazon MSK 主控台，網址為 [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/)。

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)