步驟 4：在 Amazon MSK 叢集中建立主題

在開始使用 Amazon MSK 的這個步驟中，您可以在用戶端機器上安裝 Apache Kafka 用戶端程式庫和工具，然後建立主題。

警告

本教學課程中使用的 Apache Kafka 版本號僅為示例。我們建議您使用與 MSK 叢集版本相同的用戶端版本。較舊的用戶端版本可能缺少特定功能和重大錯誤修正。

尋找 MSK 叢集的版本

1. 移至 https://eu-west-2.console.aws.amazon.com/msk/

2. 選取 MSK 叢集。

3. 請記住叢集上使用的 Apache Kafka 版本。

4. 使用步驟 3 中取得的版本取代本教學課程中 Amazon MSK 版本號碼的執行個體。

若要在用戶端機器上建立主題

1. 在 https://console.aws.amazon.com/ec2/ 開啟 Amazon EC2 主控台。

2. 在導覽窗格中，選擇執行個體。然後選取您在 步驟 3：建立用戶端機器 建立的用戶端機器名稱旁邊的核取方塊。

3. 選擇動作，然後選擇連線。遵循主控台的指示操作，連線至您的用戶端機器。

4. 執行下列命令，在用戶端機器上安裝 Java：

   sudo yum -y install java-11

5. 執行下列命令下載 Apache Kafka。

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

   注意

   如果您想要使用此命令中以外的鏡像網站，您可以在 Apache 網站上選擇不同的鏡像網站。

6. 在您在先前步驟中下載 TAR 檔案的目錄中執行下列命令。

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

7. 前往 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。

8. 前往 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

9. 開啟位於 https://console.aws.amazon.com/msk/ 的 Amazon MSK 主控台。

10. 等待叢集的狀態變成作用中。這可能需要幾分鐘的時間。狀態變為作用中之後，選擇叢集名稱。這會帶您前往包含叢集摘要的頁面。

11. 選擇檢視用戶端資訊。

12. 複製私有端點的連線字串。

    您的每個代理程式將獲得三個端點。您只需要一個代理程式端點即可執行下列步驟。

13. 執行下列命令，使用您在上一步獲得的代理程式端點之一取代 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.

後續步驟

步驟 5：產生和取用資料