ステップ 4: トピックを作成する

Amazon MSK の使用をスタートするのこのステップでは、Apache Kafka クライアントライブラリとツールをクライアントマシンにインストールしてから、トピックを作成します。

警告

このチュートリアルで使用している Apache Kafka のバージョン番号は例にすぎません。MSK クラスターバージョンと同じバージョンのクライアントを使用することが推奨されます。古いクライアントバージョンでは、特定の機能や重大なバグ修正が欠落している可能性があります。

MSK クラスターのバージョンを確認する方法

1. https://eu-west-2.console.aws.amazon.com/msk/ に移動します

2. MSK クラスターを選択します。

3. クラスターで使用されている Apache Kafka のバージョンをメモします。

4. このチュートリアルの Amazon MSK バージョン番号のインスタンスは、ステップ 3 で取得したバージョンに置き換えてください。

クライアントマシンでトピックを作成するには

1. Amazon EC2 コンソール (https://console.aws.amazon.com/ec2/) を開きます。

2. ナビゲーションペインで、[インスタンス] を選択します。次に、「ステップ 3: クライアントマシンを作成する」で作成したクライアントマシンの名前の横にあるチェックボックスをオンにします。

3. [Actions (アクション)] を選択して、[Connect (接続)] を選択します。コンソールの指示に従ってクライアントマシンに接続します。

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/v1.1.1/aws-msk-iam-auth-1.1.1-all.jar

8. kafka_2.13-{YOUR MSK VERSION}/bin ディレクトリに移動します。次のプロパティ設定をコピーして、新しいファイルに貼り付けます。ファイルに 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. View client information (ライアント情報の表示) を選択します。

12. プライベートエンドポイントの接続文字列をコピーします。

    ブローカーごとに 3 つのエンドポイントが提供されます。次のステップに必要なブローカーエンドポイントは 1 つだけです。

13. 次のコマンドを実行し、BootstrapServer文字列を前のステップで取得したブローカーエンドポイントの 1 つに置き換えます。

    <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: データを生成および消費する