Apache Kafka トピックを作成する - Amazon Managed Streaming for Apache Kafka
トピックを作成するための環境のセットアップトピックを作成し、そのトピックにデータを書き込む

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

Apache Kafka トピックを作成する

このステップでは、以前に作成したクライアントマシンを使用して、サーバーレスクラスターにトピックを作成します。

トピックを作成するための環境のセットアップ

  • トピックを作成する前に、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

トピックを作成し、そのトピックにデータを書き込む

  1. 次の export コマンドの my-endpoint を、クラスターの作成後に保存したブートストラップサーバー文字列に置き換えます。次に、クライアントマシン上の kafka_2.12-2.8.1/bin ディレクトリに移動し、export コマンドを実行します。

    export BS=my-endpoint

  2. 次のコマンドを実行して、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 サーバーレスでデータを生成および消費する