ApsaraMQ for Kafka:Message Queue for Apache Kafka broker のクイックテストを実行する方法

手順

ApsaraMQ for Kafka broker のクイックテストを実行するには、次の手順を実行します。

1. トピックを作成する

2. メッセージを送信する

3. パーティションの状態を表示する

4. オフセットでメッセージを照会する

手順 2 ～ 4 を複数回繰り返すことができます。 繰り返したすべての手順が成功した場合、broker は期待どおりに動作しています。

トピックを作成する

1. ApsaraMQ for Kafka コンソール にログオンします。

2. リソースの分布概要 ページの セクションで、管理する ApsaraMQ for Kafka インスタンスが存在するリージョンを選択します。

   重要

   Elastic Compute Service ( ECS ) インスタンスがデプロイされているリージョンにトピックを作成する必要があります。 トピックはリージョンをまたいで使用することはできません。 たとえば、メッセージのプロデューサーとコンシューマーが中国 ( 北京 ) リージョンにデプロイされている ECS インスタンスで実行されている場合、トピックも中国 ( 北京 ) リージョンに作成する必要があります。

3. インスタンスリスト ページで、管理するインスタンスの名前をクリックします。

4. 左側のナビゲーションペインで、トピック管理 をクリックします。

5. トピック管理 ページで、トピックの作成 をクリックします。

6. トピックの作成 パネルで、トピックのプロパティを指定し、[OK] をクリックします。

   パラメーター	説明	パラメーター
   名前	トピック名。	demo
   記述	トピックの説明。	デモテスト
   パーティションの数	トピック名。	demo
   ストレージエンジン 説明 ストレージエンジンの種類を指定できるのは、Professional Editionインスタンスを使用している場合のみです。Standard Editionインスタンスを使用している場合は、デフォルトでクラウドストレージが選択されます。	トピックにメッセージを格納するために使用されるストレージエンジンの種類。 ApsaraMQ for Kafka は、次のタイプのストレージエンジンをサポートしています。 クラウドストレージ: この値を選択すると、システムはトピックにAlibaba Cloudディスクを使用し、分散モードで3つのレプリカにデータを保存します。このストレージエンジンは、低レイテンシ、高パフォーマンス、長期の耐久性、および高信頼性を備えています。インスタンスを作成したときに 仕様タイプ パラメーターを Standard Edition (High Write) に設定した場合、このパラメーターは クラウドストレージ にのみ設定できます。 ローカルストレージ: この値を選択すると、システムはオープンソース Apache Kafka の同期レプリカ (ISR) アルゴリズムを使用し、分散モードで3つのレプリカにデータを保存します。	クラウドストレージ
   メッセージタイプ	トピックのメッセージタイプ。有効な値: 通常のメッセージ: デフォルトでは、同じキーを持つメッセージは、メッセージが送信された順序で同じパーティションに保存されます。クラスター内のブローカーに障害が発生した場合、パーティションに保存されているメッセージの順序は保持されない可能性があります。ストレージエンジン パラメーターを クラウドストレージ に設定すると、このパラメーターは自動的に 通常のメッセージ に設定されます。 パーティション順位メッセージ: デフォルトでは、同じキーを持つメッセージは、メッセージが送信された順序で同じパーティションに保存されます。クラスター内のブローカーに障害が発生した場合でも、メッセージは送信された順序でパーティションに保存されます。一部のパーティションのメッセージは、パーティションが復元されるまで送信できません。ストレージエンジン パラメーターを ローカルストレージ に設定すると、このパラメーターは自動的に パーティション順位メッセージ に設定されます。	通常のメッセージ
   ログリリースポリシー	トピックで使用されるログクリーンアップポリシー。 ストレージエンジン パラメーターを ローカルストレージ に設定する場合は、ログリリースポリシー パラメーターを構成する必要があります。ストレージエンジン パラメーターをローカルストレージに設定できるのは、ApsaraMQ for Kafka Professional Edition インスタンスを使用している場合のみです。 ApsaraMQ for Kafka は、次のログクリーンアップポリシーを提供します。 Delete: デフォルトのログクリーンアップポリシーです。システムに十分なストレージ容量がある場合、メッセージは最大保存期間に基づいて保持されます。ストレージ使用率が 85% を超えると、システムはサービスの可用性を確保するために最も古いメッセージを削除します。 Compact: Apache Kafka で使用されるログ圧縮ポリシーです。ログ圧縮により、同じキーを持つメッセージの最新の値が保持されます。このポリシーは、障害が発生したシステムの復元や、システムの再起動後のキャッシュの再読み込みなどのシナリオに適しています。たとえば、Kafka Connect または Confluent Schema Registry を使用する場合、システムの状態と構成に関する情報をログ圧縮されたトピックに保存する必要があります。 重要 ログ圧縮トピックは、Kafka Connect や Confluent Schema Registry などの特定のクラウドネイティブコンポーネントでのみ使用できます。詳細については、「aliware-kafka-demos」をご参照ください。	Compact
   タグ	トピックに添付するタグ。	demo

   トピックが作成されると、トピック管理 ページでトピックを表示できます。

メッセージの送信

作成したトピックにメッセージを送信します。

1. トピック管理 ページで、管理するトピックの名前をクリックします。トピックの詳細 ページの右上隅にある メッセージの送信を体験する をクリックします。

2. メッセージ送受信のクイック体験 パネルで、テストメッセージを送信するためのパラメーターを設定します。

   • 送信方法 パラメーターを コンソール に設定した場合は、次の手順を実行します。

     1. メッセージキー フィールドに、メッセージキーを入力します。例：demo。

     2. メッセージの内容 フィールドに、メッセージコンテンツを入力します。例：{"key": "test"}。

     3. 指定されたパーティションに送信 パラメーターを設定し、テストメッセージを特定のパーティションに送信するかどうかを指定します。

        • テストメッセージを特定のパーティションに送信する場合は、はい をクリックし、パーティション ID フィールドにパーティション ID を入力します。例：0。パーティション ID を照会する方法については、パーティションステータスの表示 をご参照ください。

        • テストメッセージを特定のパーティションに送信しない場合は、いいえ をクリックします。

     4. ApsaraMQ for Kafka SDK を使用するか、[メッセージの送受信を開始] パネルに表示されている Docker コマンドを実行して、テストメッセージをサブスクライブします。

   • 送信方法 パラメーターを [docker] に設定した場合は、次の手順を実行して Docker コンテナーを実行します。

     1. Docker コンテナーを実行してサンプルメッセージを生成する セクションに表示されている Docker コマンドを実行して、テストメッセージを送信します。

     2. 送信後にメッセージを消費するにはどうすればよいですか？ セクションに表示されている Docker コマンドを実行して、テストメッセージをサブスクライブします。

   • 送信方法 パラメーターを [SDK] に設定した場合は、必要なプログラミング言語またはフレームワークの SDK と、テストメッセージを送受信するためのアクセス方法を選択します。

パーティションの状態の表示

指定したパーティションにメッセージを送信した後、パーティションの状態を表示します。

オフセットによるメッセージのクエリ

1. ApsaraMQ for Kafka コンソール にログオンします。

2. リソースの分布 セクションの 概要 ページで、管理する ApsaraMQ for Kafka インスタンスが存在するリージョンを選択します。

3. インスタンスリスト ページで、管理するインスタンスの名前をクリックします。

4. 左側のナビゲーションペインで、メッセージクエリ をクリックします。

5. メッセージクエリ ページで、位置によるクエリクエリモード ドロップダウンリストから を選択します。

6. Topic ドロップダウンリストからトピックを選択し、パーティション ドロップダウンリストからパーティションを選択し、開始点 フィールドにオフセット値を入力し、クエリ をクリックします。

   指定されたオフセット値以上のオフセット値を持つメッセージが表示されます。たとえば、[パーティション] パラメーターと [オフセット] パラメーターの値として 5 を指定すると、システムはパーティション 5 からオフセットが 5 以上のメッセージをクエリします。

   表 2. メッセージクエリ結果に含まれるパラメーター

   パラメーター	説明
   パーティション	メッセージが取得されるパーティション。
   オフセット	メッセージのオフセット。
   Key	メッセージキー。キーは文字列に変換されます。
   Value	メッセージ値。メッセージコンテンツとも呼ばれます。メッセージ値は文字列に変換されます。
   メッセージ作成時間	メッセージが送信された時点。値は、メッセージの送信時にクライアントが記録したタイムスタンプ、または ProducerRecord オブジェクトに指定したタイムスタンプフィールドの値です。 説明 タイムスタンプフィールドに値を指定した場合、指定した値が表示されます。 タイムスタンプフィールドに値を指定しなかった場合、メッセージが送信されたときのローカルシステム時刻が表示されます。 1970/x/x x:x:x 形式の値は、タイムスタンプフィールドが 0 または無効な値として指定されていることを示します。 ApsaraMQ for Kafka バージョン 0.9 以前のクライアントでは、タイムスタンプフィールドを指定できません。
   操作	キーのダウンロード をクリックして、メッセージキーをダウンロードします。 値のダウンロード をクリックして、メッセージコンテンツをダウンロードします。 重要 取得された各メッセージの最大 1 KB のコンテンツを ApsaraMQ for Kafka コンソールに表示できます。取得したメッセージのサイズが 1 KB を超える場合、システムはコンテンツを自動的に切り捨てます。完全なメッセージコンテンツを表示する場合は、メッセージをダウンロードしてください。 取得したメッセージの最大 10 MB を一度にダウンロードできます。取得したメッセージのサイズが 10 MB を超える場合は、メッセージコンテンツの最初の 10 MB のみダウンロードできます。