ステップ 3: クライアントマシンを作成する - Amazon Managed Streaming for Apache Kafka

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

ステップ 3: クライアントマシンを作成する

このステップでは、2 つのタスクを実行します。最初のタスクでは、Apache Kafka クライアントマシンとして使用する Amazon EC2 インスタンスを作成します。2 番目のタスクでは、マシンに Java および Apache Kafka ツールをインストールします。

クライアントマシンを作成するには
  1. Amazon EC2 コンソール (https://console.aws.amazon.com/ec2/) を開きます。

  2. [インスタンスを起動] を選択します。

  3. クライアントマシンにわかりやすい [名前] (msk-serverless-tutorial-client など) を入力します。

  4. [Amazon マシンイメージ (AMI) のタイプ] については、[Amazon Linux 2 AMI (HVM) - カーネル 5.10、SSD ボリュームタイプ] を選択したままにします。

  5. t2.micro インスタンスタイプを選択したままにします。

  6. [キーペア (ログイン)] で、[新しいキーペアの作成] を選択します。[キーペア名]MSKServerlessKeyPair と入力します。[キーペアのダウンロード] を選択します。既存のキーペアを使用することもできます。

  7. [ネットワーク設定] で、[編集] を選択します。

  8. [VPC] で、サーバーレスクラスターの仮想プライベートクラウド (VPC) の ID を入力します。これは、先ほどクラスターの作成後に保存した ID を持つ Amazon VPC サービスに基づく VPC です。

  9. サブネットには、クラスターの作成後に ID を保存したサブネットを選択します。

  10. [ファイアウォール (セキュリティグループ)] では、クラスターに関連付けられたセキュリティグループを選択します。この値は、そのセキュリティグループから同じセキュリティグループ内へのトラフィックを許可するインバウンドルールが存在する場合に機能します。このようなルールにより、同じセキュリティグループのメンバー同士が互いに通信できるようになります。詳細については、Amazon VPC デベロッパーガイドのセキュリティグループルールを参照してください。

  11. [詳細情報] セクションを展開し、ステップ 2: IAM ロールを作成する で作成した IAM ロールを選択します。

  12. [Launch] (起動する) を選択します。

  13. 左側のナビゲーションペインで、[Instances] (インスタンス) をクリックします。新しく作成した Amazon EC2 インスタンスを表す行のチェックボックスをオンにします。これ以降は、このインスタンスのことをクライアントマシンと呼びます。

  14. [Connect] (接続) を選択し、指示に従ってクライアントマシンに接続します。

クライアントマシンで Apache Kafka クライアントツールを設定するには
  1. クライアントマシンに Java をインストールするには、次のコマンドを実行します。

    sudo yum -y install java-11
  2. トピックの作成とデータの送信に必要な Apache Kafka ツールを入手するには、次のコマンドを実行します。

    wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz
    tar -xzf kafka_2.12-2.8.1.tgz
  3. kafka_2.12-2.8.1/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
  4. kafka_2.12-2.8.1/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

次のステップ

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