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

# 建立 Apache Kafka 主題
<a name="msk-serverless-create-topic"></a>

在此步驟中，您可以使用先前建立的用戶端機器，在無伺服器叢集上建立主題。

**Topics**
+ [設定您的環境以建立主題](#msk-serverless-create-topic-prerequisites)
+ [建立主題並寫入資料](#msk-serverless-create-topic-procedure)

## 設定您的環境以建立主題
<a name="msk-serverless-create-topic-prerequisites"></a>
+ 建立主題之前，請確定您已將 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
  ```

  使用 MSK Serverless 叢集進行 IAM 身分驗證時，需要此 JAR 檔案。
+ 執行 Kafka 命令時，您可能需要確保 `classpath`包含 AWS MSK IAM JAR 檔案。若要執行此操作，請執行以下其中一項操作：
  + 將`CLASSPATH`環境變數設定為包含 Kafka 程式庫，如下列範例所示。

    ```
    export CLASSPATH=<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar
    ```
  + 使用具有明確 的完整 Java 命令來執行 Kafka 命令`classpath`，如下列範例所示。

    ```
    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
    ```

## 建立主題並寫入資料
<a name="msk-serverless-create-topic-procedure"></a>

1. 在下列 `export` 命令中，使用建立叢集之後儲存的引導伺服器字串取代 *my-endpoint*。接著前往用戶端機器上的 `kafka_2.12-2.8.1/bin` 目錄，執行 `export` 命令。

   ```
   export BS=my-endpoint
   ```

1. 執行下列命令，建立名為 `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 中產生和使用資料](msk-serverless-produce-consume.md)