翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
MSK Serverless クラスターにアクセスするためのクライアントマシンを作成する
このステップでは、2 つのタスクを実行します。最初のタスクは、Apache Kafka クライアントマシンとして使用する Amazon EC2インスタンスを作成することです。2 番目のタスクでは、マシンに Java および Apache Kafka ツールをインストールします。
クライアントマシンを作成するには
で Amazon EC2コンソールを開きますhttps://console.aws.amazon.com/ec2/
。 Launch instance (インスタンスの起動) を選択します。
クライアントマシンにわかりやすい [名前] (
msk-serverless-tutorial-client
など) を入力します。-
Amazon Linux 2 AMI (HVM) - カーネル 5.10、Amazon マシンイメージ () タイプ にSSDボリュームタイプを選択したままにします。 AMI
-
t2.micro インスタンスタイプを選択したままにします。
-
[キーペア (ログイン)] で、[新しいキーペアの作成] を選択します。[キーペア名] に
MSKServerlessKeyPair
と入力します。[キーペアのダウンロード] を選択します。既存のキーペアを使用することもできます。 -
[ネットワーク設定] で、[編集] を選択します。
-
にVPC、サーバーレスクラスター の仮想プライベートクラウド (VPC) の ID を入力します。これは、クラスターの作成後に保存した ID を持つ Amazon VPCサービスVPCに基づいています。
サブネットには、クラスターの作成後に ID を保存したサブネットを選択します。
-
[ファイアウォール (セキュリティグループ)] では、クラスターに関連付けられたセキュリティグループを選択します。この値は、そのセキュリティグループから同じセキュリティグループ内へのトラフィックを許可するインバウンドルールが存在する場合に機能します。このようなルールにより、同じセキュリティグループのメンバー同士が互いに通信できるようになります。詳細については、「Amazon VPCデベロッパーガイド」の「セキュリティグループルール」を参照してください。
-
詳細セクションを展開し、 で作成したIAMロールを選択しますMSK Serverless クラスターでトピックのIAMロールを作成する。
-
[Launch] (起動する) を選択します。
-
左側のナビゲーションペインで、[Instances] (インスタンス) をクリックします。次に、新しく作成した Amazon EC2インスタンスを表す行のチェックボックスをオンにします。これ以降は、このインスタンスのことをクライアントマシンと呼びます。
-
[Connect] (接続) を選択し、指示に従ってクライアントマシンに接続します。
クライアントマシンで Apache Kafka クライアントツールを設定するには
クライアントマシンに Java をインストールするには、次のコマンドを実行します。
sudo yum -y install java-11
トピックの作成とデータの送信に必要な 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
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
-
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
次のステップ