MSK Serverless クラスターにアクセスするためのクライアントマシンを作成する - Amazon Managed Streaming for Apache Kafka

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

MSK Serverless クラスターにアクセスするためのクライアントマシンを作成する

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

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

  2. Launch instance (インスタンスの起動) を選択します。

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

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

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

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

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

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

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

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

  11. 詳細セクションを展開し、 で作成したIAMロールを選択しますMSK Serverless クラスターでトピックの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 MSKIAMJARでは、クライアントマシンがクラスターにアクセスできるようになります。

    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

次のステップ

Apache Kafka トピックを作成する