翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
# Amazon MSK の使用を開始する
このチュートリアルでは、MSK クラスターを作成し、データを生成および消費し、メトリクスを使用してクラスターのヘルスをモニタリングする方法の例を示します。この例は、MSK クラスターを作成するときに選択できるすべてのオプションを表しているわけではありません。このチュートリアルのさまざまな部分では、簡単にするためにデフォルトのオプションを選択します。これは、MSK クラスターまたはクライアント インスタンスを設定するために機能する唯一のオプションであることを意味するものではありません。
**Topics**
+ [ステップ 1: MSK プロビジョニングされたクラスターを作成する](create-cluster.md)
+ [ステップ 2: Amazon MSK クラスターでトピックを作成するためのアクセス権を付与する IAM ロールを作成する](create-client-iam-role.md)
+ [ステップ 3: クライアントマシンを作成する](create-client-machine.md)
+ [ステップ 4: Amazon MSK クラスターにトピックを作成する](create-topic.md)
+ [ステップ 5: データを生成および消費する](produce-consume.md)
+ [ステップ 6: Amazon CloudWatch を使用して Amazon MSK メトリクスを表示する](view-metrics.md)
+ [ステップ 7: このチュートリアル用に作成された AWS リソースを削除する](delete-cluster.md)
# ステップ 1: MSK プロビジョニングされたクラスターを作成する
[Amazon MSK の使用を開始する](getting-started.md) このステップでは、Amazon MSK クラスターを作成します。このクラスター AWS マネジメントコンソール を作成するには、 の**クイック作成**オプションを使用します。
**を使用して Amazon MSK クラスターを作成するには AWS マネジメントコンソール**を使用してクラスターを作成する AWS マネジメントコンソール
1. にサインインし AWS マネジメントコンソール、[https://console.aws.amazon.com/msk/home?region=us-east-1\$1/home/](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/) で Amazon MSK コンソールを開きます。
1. **[クラスターを作成]** を選択します。
1. **[作成方法]** では、**[クイック作成]** オプションを選択したままにします。**[クイック作成]** オプションを使用すると、デフォルト設定でクラスターを作成できます。
1. **[クラスター名]** には、クラスターのわかりやすい名前を入力します。例えば、**MSKTutorialCluster**。
1. **一般的なクラスタープロパティ**の場合は、次の操作を行います。
1. **[クラスタータイプ]** に **[プロビジョンド]** を選択します。
1. ブローカーで実行する **Apache Kafka バージョン** を選択します。比較テーブルを表示するには、**バージョン互換性の表示**を選択します。
1. **ブローカータイプ**で、スタンダードブローカーまたは Express ブローカーを選択します。
1. **ブローカーサイズ**を選択します。
1. このチュートリアルの後半で必要になるため、**[すべてのクラスター設定]** の下の表から次の設定の値をコピーして保存します。
+ VPC
+ サブネット
+ VPC に関連付けられたセキュリティグループ。
1. **[クラスターを作成]** を選択します。
1. **[クラスターの概要]** ページでクラスターの **[ステータス]** を確認します。Amazon MSK がクラスターをプロビジョニングすると、ステータスが **[作成中]** から **[アクティブ]** に変わります。ステータスが **[アクティブ]** の場合、クラスターに接続できます。クラスターのステータスの詳細については、「[MSK プロビジョンドクラスターの状態を理解する](msk-cluster-states.md)」を参照してください。
**次のステップ**
[ステップ 2: Amazon MSK クラスターでトピックを作成するためのアクセス権を付与する IAM ロールを作成する](create-client-iam-role.md)
# ステップ 2: Amazon MSK クラスターでトピックを作成するためのアクセス権を付与する IAM ロールを作成する
このステップでは、2 つのタスクを実行します。最初のタスクは、クラスターでトピックを作成し、それらのトピックにデータを送信するためのアクセスを許可する IAM ポリシーを作成することです。2 番目のタスクは、IAM ロールを作成し、作成したポリシーをそのロールに関連付けることです。後のステップでは、このロールを引き受けるクライアントマシンを作成し、それを使用してクラスター上にトピックを作成し、そのトピックにデータを送信します。
**トピックを作成し、書き込むことを可能にする IAM ポリシーを作成する**IAM ポリシーを作成する
1. IAM コンソール ([https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/)) を開きます。
1. ナビゲーションペインで [**Policies**] (ポリシー) を選択します。
1. [**Create policy**] (ポリシーの作成) を選択します。
1. **ポリシーエディター**で、**JSON** タブを選択し、エディタウィンドウの JSON を次の JSON に置き換えます。
以下の例では、以下を置き換えます。
+ *region* と、クラスターを作成した AWS リージョン のコード。
+ アカウント ID の例: *123456789012*。 AWS アカウント
+ *MSKTutorialCluster* および *MSKTutorialCluster*/*7d7131e1-25c5-4e9a-9ac5-ea85bee4da11-14* を、あなたのクラスターの名前とその ID に置き換えます。
------
#### [ JSON ]
****
```
{
"Version":"2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Action": [
"kafka-cluster:Connect",
"kafka-cluster:AlterCluster",
"kafka-cluster:DescribeCluster"
],
"Resource": [
"arn:aws:kafka:us-east-1:123456789012:cluster/MSKTutorialCluster/7d7131e1-25c5-4e9a-9ac5-ea85bee4da11-14"
]
},
{
"Effect": "Allow",
"Action": [
"kafka-cluster:*Topic*",
"kafka-cluster:WriteData",
"kafka-cluster:ReadData"
],
"Resource": [
"arn:aws:kafka:us-east-1:123456789012:topic/MSKTutorialCluster/*"
]
},
{
"Effect": "Allow",
"Action": [
"kafka-cluster:AlterGroup",
"kafka-cluster:DescribeGroup"
],
"Resource": [
"arn:aws:kafka:us-east-1:123456789012:group/MSKTutorialCluster/*"
]
}
]
}
```
------
安全なポリシーの記述方法については、「[IAM アクセスコントロール](iam-access-control.md)」を参照してください。
1. [**次へ**] を選択します。
1. **[レビューと作成]** ページで、以下の操作を実行します。
1. **ポリシー名**にわかりやすい名前 (**msk-tutorial-policy** など) を入力します。
1. **このポリシーで定義されているアクセス許可**で、ポリシーで定義されたアクセス許可を確認および/または編集します。
1. (オプション) ポリシーの識別、整理、検索を簡単にするには、キーと値のペアとして**新規タグを追加**します。たとえば、**Environment** と **Test** のキーと値のペアを使用してポリシーにタグを追加します。
タグの使用の詳細については、*IAM ユーザーガイド*の[「 AWS Identity and Access Management リソースのタグ](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html)」を参照してください。
1. [**Create policy**] (ポリシーの作成) を選択します。
**IAM ロールを作成し、ポリシーを適用する**
1. ナビゲーションペインで **ロール**を選択してから、**ロールを作成する**を選択します。
1. **[信頼されたエンティティを選択]** ページで、以下の操作を実行してください。
1. **信頼できるエンティティタイプ** で、**AWS のサービス** を選択します。
1. ［**サービスまたはユースケース**］で、［**EC2**］を選択します。
1. **[ユースケース]** で、**[EC2]** を選択してください。
1. [**次へ**] を選択します。
1. **[アクセス許可を追加]** ページで、以下を実行します。
1. **権限ポリシー**の下にある検索ボックスに、このチュートリアル用に以前に作成したポリシーの名前を入力します。次に、ポリシー名の左側にある、チェックボックスを選択してください。
1. (オプション) [アクセス許可の境界](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_boundaries.html)を設定します。このアドバンスド機能は、サービスロールで使用できますが、サービスにリンクされたロールではありません。アクセス許可の境界の設定については、*IAM ユーザーガイド*の「[ロールの作成とポリシーのアタッチ (コンソール)](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_job-functions_create-policies.html)」を参照してください。
1. [**次へ**] を選択します。
1. **[名前を付けて、レビューし、作成する]** ページで、以下の操作を実行します。
1. **ロール名**に、わかりやすい名前 (**msk-tutorial-role** など) を入力します。
**重要**
ロールに名前を付けるときは、次のことに注意してください。
ロール名は 内で一意である必要があり AWS アカウント、大文字と小文字を区別することはできません。
例えば、**PRODROLE** と **prodrole** の両方の名前でロールを作成することはできません。ロール名がポリシーまたは ARN の一部として使用される場合、ロール名は大文字と小文字が区別されます。ただし、サインインプロセスなど、コンソールにロール名がユーザーに表示される場合、ロール名は大文字と小文字が区別されません。
他のエンティティがロールを参照する可能性があるため、ロールを作成した後にロール名を編集することはできません。
1. (オプション) **[説明]** にロールの説明を入力します。
1. (オプション) ロールの使用事例とアクセス許可を編集するには、[**ステップ 1: 信頼されたエンティティを選択**] または [**ステップ 2: アクセス権限を追加**] のセクションで [**編集**] を選択します。
1. (オプション) ロールの識別、整理、検索を簡単にするには、キーと値のペアとして**新規タグを追加**します。たとえば、**ProductManager** と **John** のキーと値のペアを使用してロールにタグを追加します。
タグの使用の詳細については、*IAM ユーザーガイド*の[「 AWS Identity and Access Management リソースのタグ](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html)」を参照してください。
1. ロールを確認したら、**[ロールを作成]** を選択します。
**次のステップ**
[ステップ 3: クライアントマシンを作成する](create-client-machine.md)
# ステップ 3: クライアントマシンを作成する
「[Amazon MSK の使用を開始する](getting-started.md)」のこのステップでは、クライアントマシンを作成します。このクライアントマシンを使用して、データを生成および消費するトピックを作成します。簡単にするために、このクライアントマシンを MSK クラスターに関連付けられた VPC に作成します。これにより、クライアントがクラスターに簡単に接続できるようになります。
**クライアントマシンを作成するには**クライアントマシンを作成するには
1. Amazon EC2 コンソールの [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/) を開いてください。
1. Amazon EC2 コンソールダッシュボードで、[**インスタンスを起動**] を選択してください。
1. **[名前とタグ]** の下にある、**[名前]** 欄に、クライアントマシンを簡単にわかりやすい、識別できる名前を入力してください。例えば、**MSKTutorialClient**。
1. **アプリケーションイメージと OS イメージ (Amazon マシンイメージ)** の **Amazon マシンイメージ (AMI)** で、**Amazon Linux 2 AMI (HVM) - カーネル 5.10、SSD ボリュームタイプ**を選択します。
1. **[インスタンスタイプ]** については、デフォルト選択の **t2.micro** をそのまま使用してください。
1. **キーペア (ログイン)** で、既存のキーペアを選択するか、新しいキーペアを作成します。インスタンスへの接続にキーペアが必要ない場合は、**[キーペアなしで続行 (非推奨)]** を選択できます。
新しいキーペアを作成するには、以下の操作を行います。
1. **Create New Key Pair (新しいキーペアの作成)** を選択します。
1. **[Key Pair Name]** (キーペア名) に **MSKKeyPair** と入力します。
1. **キーペアタイプ**と**プライベートキーファイル形式**については、デフォルトの選択のままにします。
1. [**キーペアの作成**] を選択してください。
既存のキーペアを使用することもできます。
1. ページを下にスクロールして**高度な詳細**セクションを展開し、次の操作を行います。
1. **IAM インスタンスプロファイル**で、クライアントマシンが引き受ける IAM ロールを選択します。
IAM ロールがない場合は、次の操作を実行してください。
1. **[新しい IAM プロファイルを作成]** を選択します。
1. [ステップ 2: IAM ロールの作成](create-client-iam-role.md) に記載されている手順を実行してください。
1. **[インスタンスを起動]** を選択します。
1. [**インスタンスの表示**] を選択します。次に、**[セキュリティグループ]** 列で、新しいインスタンスに関連付けられているセキュリティグループを選択します。セキュリティグループの ID をコピーし、後で使用できるように保存します。
1. Amazon VPC コンソール ([https://console.aws.amazon.com/vpc/](https://console.aws.amazon.com/vpc/)) を開きます。
1. ナビゲーションペインで、**[Security Groups]** (セキュリティグループ) をクリックします。「[ステップ 1: MSK プロビジョニングされたクラスターを作成する](create-cluster.md)」で ID を保存したセキュリティグループを見つけます。
1. **Inbound Rules** (インバウンドルール) タブで、**Edit inbound rules** (インバウンドルールの編集) を選択します。
1. [**ルールを追加**] を選択してください。
1. 新しいルールで、**Type** (タイプ) 列の**All traffic** (すべてのトラフィック) を選択します。**[ソース]** 列の 2 番目のフィールドで、クライアントマシンのセキュリティグループを選択します。これは、クライアントマシンインスタンスを起動した後に名前を保存したグループです。
1. [**ルールの保存**] を選択します。これで、クラスターのセキュリティグループは、クライアントマシンのセキュリティグループからのトラフィックを受け入れることができます。
**次のステップ**
[ステップ 4: Amazon MSK クラスターにトピックを作成する](create-topic.md)
# ステップ 4: Amazon MSK クラスターにトピックを作成する
[Amazon MSK の開始方法](getting-started.md)のこのステップでは、CreateTopic API でネイティブ AWS ツールを使用するか、クライアントマシンで Apache Kafka AdminClient ツールを使用するという 2 つの方法のいずれかを使用してトピックを作成できます。
**警告**
CreateTopic API で AWS ツールを使用する場合は、クラスターが要件を満たしていることを確認します。詳細については、「 [トピック APIs](https://docs.aws.amazon.com/msk/latest/developerguide/msk-topic-operations-information.html#topic-operations-requirements)」を参照してください。
**警告**
AdminClient アプローチを使用する場合、このチュートリアルで使用される Apache Kafka バージョン番号は例にすぎません。MSK クラスターバージョンと同じバージョンのクライアントを使用することが推奨されます。旧クライアントバージョンでは、特定の機能や重大なバグ修正が失われている可能性があります。
**Topics**
+ [AWS ツールを使用したトピックの作成](#create-topic-aws-tools)
+ [MSK クラスターバージョンの確認](#find-msk-cluster-version)
+ [クライアントマシン上でトピックを作成する](#create-topic-client-machine)
## AWS ツールを使用したトピックの作成
CLI、SDK、 AWS マネジメントコンソールなどの AWS ツールを使用して、MSK AWS クラスターにトピックを作成できます。 AWS SDKs このアプローチは、Kafka クライアントツールに直接アクセスすることなく、トピックを管理するための効率的な方法を提供します。
AWS ツールを使用したトピックの作成の詳細については、[CreateTopic API デベロッパーガイド](https://docs.aws.amazon.com/msk/latest/developerguide/msk-create-topic.html)を参照してください。
## MSK クラスターバージョンの確認
1. [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/) で Amazon MSK コンソールを開きます。
1. ナビゲーションバーで、クラスターを作成したリージョンを選択します。
1. MSK クラスターを選択します。
1. クラスターで使用されている Apache Kafka のバージョンをメモします。
1. このチュートリアルの Amazon MSK バージョン番号のインスタンスは、ステップ 3 で取得したバージョンに置き換えてください。
## クライアントマシン上でトピックを作成する
1. **クライアントマシンへ接続します。**
1. Amazon EC2 コンソールの [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/) を開いてください。
1. ナビゲーションペインで、[**インスタンス**] を選択してください。次に、「[ステップ 3: クライアントマシンを作成する](create-client-machine.md)」で作成したクライアントマシンの名前の横にあるチェックボックスを選択します。
1. [**Actions (アクション)**] を選択して、[**Connect (接続)**] を選択します。コンソールの指示に従ってクライアントマシンに接続します。
1. **Java をインストールし、Kafka バージョン環境変数を設定します。**
1. クライアントマシンに Java をインストールするには、次のコマンドを実行します。
```
sudo yum -y install java-11
```
1. 次のコマンドに示すように、MSK クラスターの [Kafka バージョン](#find-msk-cluster-version)を環境変数 `KAFKA_VERSION` に保存します。この情報は、セットアップ全体で必要になります。
```
export KAFKA_VERSION={KAFKA VERSION}
```
例えば、バージョン 3.6.0 を使用する場合、以下のコマンドを実行します。
```
export KAFKA_VERSION=3.6.0
```
1. **Apache Kafka をダウンロードして抽出します。**
1. 次のコマンドを実行して、Apache Kafka をダウンロードします。
```
wget https://archive.apache.org/dist/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz
```
**注記**
以下のリストは、問題が発生した場合に使用できる代替 Kafka ダウンロード情報を示しています。
接続の問題が発生したり、ミラーサイトを使用したりする場合は、次のコマンドに示すように、Apache ミラーセレクタを試してください。
```
wget https://www.apache.org/dyn/closer.cgi?path=/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz
```
[Apache Kafka ウェブサイト](https://kafka.apache.org/downloads)から直接適切なバージョンをダウンロードします。
1. 前のステップで TAR ファイルをダウンロードしたディレクトリで次のコマンドを実行します。
```
tar -xzf kafka_2.13-$KAFKA_VERSION.tgz
```
1. 新しく作成したディレクトリへのフルパスを`KAFKA_ROOT`環境変数内に保存します。
```
export KAFKA_ROOT=$(pwd)/kafka_2.13-$KAFKA_VERSION
```
1. **MSK クラスターの認証を設定します。**
1. Amazon [MSK IAM クライアントライブラリの最新バージョン](https://github.com/aws/aws-msk-iam-auth/releases/latest)を検索します。このライブラリを使用すると、クライアントマシンは IAM 認証を使用して MSK クラスターにアクセスできます。
1. 以下のコマンドを使用して、 `$KAFKA_ROOT/libs` ディレクトリに移動し、前のステップで見つけた関連する Amazon MSK IAM JAR をダウンロードします。必ず*\$1LATEST VERSION\$1*をダウンロードする実際のバージョン番号に置き換えてください。
```
cd $KAFKA_ROOT/libs
```
```
wget https://github.com/aws/aws-msk-iam-auth/releases/latest/download/aws-msk-iam-auth-{LATEST VERSION}-all.jar
```
**注記**
MSK クラスターとやり取りする Kafka コマンドを実行する前に、Java クラスパスに Amazon MSK IAM JAR ファイルを追加する必要がある場合があります。次の例に示すように、`CLASSPATH`環境変数を設定します。
```
export CLASSPATH=$KAFKA_ROOT/libs/aws-msk-iam-auth-{LATEST VERSION}-all.jar
```
これにより、セッション全体の `CLASSPATH` が設定され、以降のすべての Kafka コマンドで JAR を使用できるようになります。
1. `$KAFKA_ROOT/config` ディレクトリに移動して、クライアント設定ファイルを作成します。
```
cd $KAFKA_ROOT/config
```
1. 次のプロパティ設定をコピーして、新しいファイルに貼り付けます。**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
```
1. **(オプション) Kafka ツールの Java ヒープサイズを調整します。**
メモリ関連の問題が発生した場合、または多数のトピックやパーティションを扱う場合は、Java ヒープサイズを調整できます。これを行うには、Kafka コマンドを実行する前に `KAFKA_HEAP_OPTS`環境変数を設定します。
次の例では、最大ヒープサイズと初期ヒープサイズの両方を 512 メガバイトに設定します。これらの値は、特定の要件と利用可能なシステムリソースに応じて調整してください。
```
export KAFKA_HEAP_OPTS="-Xmx512M -Xms512M"
```
1. **クラスター接続情報を取得します。**
1. [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/) で Amazon MSK コンソールを開きます。
1. クラスターのステータスが **[アクティブ]** になるまで待ちます。この処理には数分かかることがあります。ステータスが **[アクティブ]** になったら、クラスター名を選択します。これにより、そのクラスターの概要を含むページに移動します。
1. **View client information** (ライアント情報の表示) を選択します。
1. プライベートエンドポイントの接続文字列をコピーします。
ブローカーごとに 3 つのエンドポイントが提供されます。次のコマンドに示すように、これらの接続文字列の 1 つを環境変数 `BOOTSTRAP_SERVER` に保存します。** を接続文字列の実際の値に置き換えます。
```
export BOOTSTRAP_SERVER=
```
1. **次のコマンドを実行して、トピックを作成します。**
```
$KAFKA_ROOT/bin/kafka-topics.sh --create --bootstrap-server $BOOTSTRAP_SERVER --command-config $KAFKA_ROOT/config/client.properties --replication-factor 3 --partitions 1 --topic MSKTutorialTopic
```
`client.properties` ファイルの `NoSuchFileException` を取得した場合は、このファイルが Kafka bin ディレクトリ内の現在の作業ディレクトリに存在することを確認してください。
**注記**
セッション全体に`CLASSPATH`環境変数を設定しない場合は、代わりに各 Kafka コマンドに `CLASSPATH`変数をプレフィックスできます。このアプローチでは、クラスパスはその特定のコマンドにのみ適用されます。
```
CLASSPATH=$KAFKA_ROOT/libs/aws-msk-iam-auth-{LATEST VERSION}-all.jar \
$KAFKA_ROOT/bin/kafka-topics.sh --create \
--bootstrap-server $BOOTSTRAP_SERVER \
--command-config $KAFKA_ROOT/config/client.properties \
--replication-factor 3 \
--partitions 1 \
--topic MSKTutorialTopic
```
1. **(任意) トピックが正常に作成されたことを確認してください。**
1. コマンドが成功した場合、次のメッセージが表示されます。 `Created topic MSKTutorialTopic.`
1. トピックが存在することを確認するために、すべてのトピックを一覧表示します。
```
$KAFKA_ROOT/bin/kafka-topics.sh --list --bootstrap-server $BOOTSTRAP_SERVER --command-config $KAFKA_ROOT/config/client.properties
```
コマンドが失敗した場合、またはエラーが発生した場合は、トラブルシューティング情報について「[Amazon MSK クラスターをトラブルシューティングする](troubleshooting.md)」を参照してください。
1. **(オプション) この チュートリアル で使用した環境変数を削除します。**
このチュートリアルの次の手順で環境変数を維持したい場合は、この手順をスキップしてください。そうでない場合は、次の例に示すようにこれらの変数を解除できます。
```
unset KAFKA_VERSION KAFKA_ROOT BOOTSTRAP_SERVER CLASSPATH KAFKA_HEAP_OPTS
```
**次のステップ**
[ステップ 5: データを生成および消費する](produce-consume.md)
# ステップ 5: データを生成および消費する
「[Amazon MSK の使用を開始する](getting-started.md)」のこのステップでは、データを生成および消費します。
**メッセージを生成および消費するには**メッセージ を生成および消費する
1. 次のコマンドを実行して、コンソールプロデューサーを起動します。
```
$KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic
```
1. 必要なメッセージを入力して、**Enter** キーを押します。このステップを 2、3 回繰り返します。行を入力して [**Enter**] キーを押すたびに、その行は個別のメッセージとして Apache Kafka クラスターに送信されます。
1. クライアントマシンへの接続を開いたままにして、そのマシンへ 2 番目の別の接続を新しいウィンドウで開きます。これは新しい セッション であるため、 `KAFKA_ROOT` および `BOOTSTRAP_SERVER`環境変数を再度設定します。これらの環境変数の設定方法に関する情報は、「[クライアントマシン上でトピックを作成する](create-topic.md#create-topic-client-machine)」を参照してください。
1. クライアントマシンへの 2 番目の接続文字列を使用して、コンソールコンシューマーを作成するために次のコマンドを実行します。
```
$KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic --from-beginning
```
コンソール プロデューサー コマンドを使用した際に入力したメッセージが表示され始めます。
1. プロデューサーウィンドウにさらにメッセージを入力し、コンシューマーウィンドウに表示されるようにします。
**次のステップ**
[ステップ 6: Amazon CloudWatch を使用して Amazon MSK メトリクスを表示する](view-metrics.md)
# ステップ 6: Amazon CloudWatch を使用して Amazon MSK メトリクスを表示する
[Amazon MSK の使用をスタートする](getting-started.md)のこのステップでは、Amazon CloudWatch の Amazon MSK メトリクスを確認します。
**CloudWatch で Amazon MSK メトリクスを表示するには**CloudWatch でメトリクスを表示する
1. CloudWatch コンソールの [https://console.aws.amazon.com/cloudwatch/](https://console.aws.amazon.com/cloudwatch/) を開いてください。
1. ナビゲーションペインで **Metrics** (メトリクス) を選択します。
1. [**All metrics (すべてのメトリクス)**] タブを選択し、[**AWS/Kafka**] を選択します。
1. ブローカーレベルのメトリクスを表示するには、[**Broker ID, Cluster Name (ブローカー ID、クラスター名)**] を選択します。クラスターレベルのメトリクスの場合は、[**Cluster Name (クラスター名)**] を選択します。
1. (オプション) グラフペインで、統計と期間を選択し、これらの設定を使用して CloudWatch アラームを作成します。
**次のステップ**
[ステップ 7: このチュートリアル用に作成された AWS リソースを削除する](delete-cluster.md)
# ステップ 7: このチュートリアル用に作成された AWS リソースを削除する
「[Amazon MSK の使用を開始する](getting-started.md)」の最後のステップでは、このチュートリアルで作成した MSK クラスターとクライアントマシンを削除します。
**を使用してリソースを削除するには AWS マネジメントコンソール**を使用してリソースを削除する AWS マネジメントコンソール
1. [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/) で Amazon MSK コンソールを開きます。
1. クラスターの名前を選択します。例えば、**MSKTutorialCluster** などです。
1. [**アクション**] を選択してから、[**削除**] をクリックします。
1. Amazon EC2 コンソールの [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/) を開いてください。
1. クライアントマシン用に作成したインスタンス (例えば **MSKTutorialClient**) を選択します。
1. **[Instance state]** (インスタンスの状態) を選択し、**[Terminate instance]** (インスタンスの終了) をクリックします。
**IAM ポリシーとロールを削除するには**IAM ポリシーとロールを削除する
1. IAM コンソール ([https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/)) を開きます。
1. ナビゲーションペインで **[Roles]** (ロール) を選択します。
1. 検索ボックスに、このチュートリアル用に作成した IAM ロールの名前を入力します。
1. ロールを選択します。**[ロールの削除]** を選択し、削除を確定します。
1. ナビゲーションペインで [**Policies**] (ポリシー) を選択します。
1. 検索ボックスに、このチュートリアル用に作成したポリシーの名前を入力します。
1. ポリシーを選択すると、その概要ページが開きます。ポリシーの**[Summary]** (概要) ページで **[Delete policy]** (ポリシーの削除) を選択します。
1. **[Delete]** (削除) をクリックします。