翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

# 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>
+ トピックを作成する前に、MSK AWS 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
  ```

  この JAR ファイルは、MSK Serverless クラスターでの IAM 認証に必要です。
+ Kafka コマンドを実行するときは、 に AWS MSK IAM JAR ファイル`classpath`が含まれていることを確認する必要がある場合があります。これを行うには、次のいずれかを実行します。
  + 次の例に示すように、Kafka ライブラリを含めるように`CLASSPATH`環境変数を設定します。

    ```
    export CLASSPATH=<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar
    ```
  + 次の例に示すように、明示的な `classpath` を指定した完全な Java コマンドを使用して Kafka コマンドを実行します。

    ```
    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 サーバーレスでデータを生成および消費する](msk-serverless-produce-consume.md)