このトピックでは、Message Queue for Apache Kafka のインスタンスエディションについて説明します。この情報を参考に、ビジネス要件に最適なエディションを選択してください。
インスタンスタイプ
シングル AZ：サービスとデータは単一のアベイラビリティーゾーンにデプロイされます。ゾーンレベルの障害が発生した場合、サービスが利用できなくなり、データ損失のリスクがあります。シングル AZ インスタンスを選択する場合は、別のリージョンにインスタンスを作成し、コネクタを使用してメッセージをバックアップすることを推奨します。詳細については、「シングルゾーンディザスタリカバリのベストプラクティス」をご参照ください。
マルチ AZ：サービスとデータは複数のアベイラビリティーゾーンにまたがってデプロイされます。このアーキテクチャにより、単一のアベイラビリティーゾーンで障害が発生した場合でも、サービス中断とデータ損失を防ぐことができます。ミッションクリティカルなサービスには、マルチ AZ デプロイを推奨します。
以下の表では、Message Queue for Apache Kafka のインスタンスエディションについて説明します。
項目 | Standard edition (High-write) | Professional edition (High-write) | Professional edition (High-read) | Serverless basic edition | Serverless standard edition | Serverless professional edition |
ストレージコスト | リザーブドキャパシティ。コストはセルフマネージドクラスターと同等です。 例えば、300 GB のディスクを購入した場合、ビジネスデータに 100 GB を利用でき、残りの 200 GB はレプリカ用に予約されます。 | リザーブドキャパシティ。セルフマネージドクラスターと比較して最大 66% のコスト削減が可能です。 例えば、300 GB のディスクを購入した場合、300 GB すべてをビジネスデータに利用できます。レプリカ用の追加 600 GB のストレージは無料で提供されます。 | 従量課金モデル。実際に使用したストレージ容量と保持期間に基づいて課金されます。セルフマネージドクラスターでクラウドディスクを使用する場合と比較して、ストレージコストを 70% 以上削減できます。 | |||
コンピューティングコスト | リザーブドキャパシティ | リザーブドキャパシティ | 従量課金モデル | |||
サービス中断 | 長時間のデータリバランスを必要とせず、突発的なトラフィックスパイクに迅速にスケーリングして対応します。 | |||||
エラスティックアーキテクチャ | スケールアウト後、新しい読み取りおよび書き込み操作に数秒以内で対応できます。 | ストレージとコンピューティングの分離アーキテクチャにより、読み取り、書き込み、およびパーティション移行が数秒以内に完了します。 | ||||
シームレスな垂直スケーリング | サポートされていません | サポートされていません | サポートされていません | 手動スケーリングが必要です。 |
|
|
ピーク時の読み取り/書き込みトラフィック比 | 1:1 | 1:1 | 3:1 | 3:1 | ||
デプロイメントアーキテクチャ | 共有インスタンス (論理的隔離) | 専用インスタンス (物理クラスターを専有) | 共有インスタンス (論理的隔離) | 専用インスタンス (物理クラスターを専有) | ||
トピック TTL | サポートされていません | ローカルストレージでサポートされます | 完全サポート | |||
メッセージ保持期間 | 最大 7 日間 | ユースケースに応じてカスタマイズ可能です。 | 無制限の保持をサポートしており、デフォルトの上限は 1 年です。より長い保持期間をご希望の場合は、チケットを送信してください。 | |||
ディザスタリカバリ | コンピューティングノードとストレージノードは単一のアベイラビリティーゾーンにデプロイされます。 | マルチ AZ デプロイをサポートします。シングル AZ デプロイを選択した場合、コンピューティングノードとストレージノードの両方が単一のアベイラビリティーゾーンにデプロイされます。 | コンピューティングノードとストレージノードは単一のアベイラビリティーゾーンにデプロイされます。 | 3 つのアベイラビリティーゾーンにまたがるマルチ AZ デプロイ (3AZ)。 | ||
パフォーマンスチューニング | サポートされていません | ユースケースに応じてカスタマイズ可能です。 | ユースケースに応じてカスタマイズ可能です。 | |||
ACL | サポートされていません | サポート | サポート | |||
VPC 内のメッセージ送信用 SSL 暗号化 | サポートされていません | サポート | サポート | |||
クロスゾーンデプロイ | サポートされていません | サポート | サポートされていません | サポート | ||
クライアントバージョンの互換性 | Apache Kafka クライアントのバージョン 0.11 から 3.x と互換性があります。 | Apache Kafka クライアントのバージョン 0.11 から 3.x と互換性があります。 | Apache Kafka クライアントのバージョン 0.11 から 3.x と互換性があります。 | |||
サービスレベルアグリーメント (SLA) | 99.95% | マルチ AZ デプロイの場合は 99.99%、シングル AZ デプロイの場合は 99.95% の SLA を提供します。 | 99.9% の SLA を提供します。これは Standard edition および Professional edition よりも低い水準です。このエディションは、HDD、OSS、スポットインスタンスなどの低コストリソースをより多く使用します。テストまたは安定したトラフィックのワークロードに推奨します。 高い安定性が求められるミッションクリティカルなワークロードには、Serverless standard edition または Serverless professional edition を推奨します。 | 99.95% の SLA を提供します。本番環境に推奨します。 | 3 つのアベイラビリティーゾーンにまたがるディザスタリカバリにより、99.99% の SLA を提供します。予約済みスループットが低いインスタンスに対して、より高いエラスティック性を提供します。これは推奨のエンタープライズグレードのエディションです。 | |
クラウドディスク暗号化 | サポート | サポート | サポートされていません | |||
トラフィック仕様とスロットリング
Message Queue for Apache Kafka インスタンスのトラフィック仕様は、メッセージの生成 (書き込み) と消費 (読み取り) の最大スループットを定義します。トラフィック制限の計算方法とスロットリングのトリガー条件を理解することで、パフォーマンス問題の診断に役立ちます。
ノード単位のトラフィック分散 — トラフィック仕様の上限は、インスタンス内のブローカーノード全体に均等に分散されます。例えば、3 ノード構成のインスタンスでは、各ノードのトラフィック上限は仕様全体のおよそ 3 分の 1 になります。単一ノードの実際のトラフィックがそのノード単位の上限を超えた場合、インスタンス全体のトラフィックが仕様上限に達していなくても、そのノードでスロットリングがトリガーされます。
トラフィックの偏りとスロットリング — デフォルトでは、Apache Kafka はメッセージを 3 つのレプリカに複製します。メッセージの生成が不均一な場合 (例えば、スケジュールされたバッチ送信やパーティションキーの分布の偏りなど)、トラフィックが特定のノードやパーティションに集中します。これにより、インスタンスレベルの平均トラフィックが仕様の範囲内であっても、局所的な過負荷が発生し、スロットリングがトリガーされます。
トラフィック仕様の表示 — コンソールでインスタンスリストに移動し、インスタンス名をクリックします。インスタンス情報 タブの 基本情報 セクションに、インスタンスの トラフィック仕様 が表示されます。これには、MB/s 単位の ピークトラフィックの読み取り と ピークトラフィック書き込み の値が含まれます。
ピークトラフィックの定義とパーティション数の見積もり — 仕様表に表示されるピークトラフィック値 (例: 20 MB/s) は、ビジネスサイドのピーク読み取り/書き込みトラフィックを指します。これは、アプリケーションがメッセージを生成 (書き込み) または消費 (読み取り) する際のピークスループットであり、NIC の物理的な上限ではありません。インスタンスがサポートできる実際の NIC 読み取り/書き込みトラフィックは、仕様値のおよそ 3 倍です。これは、レプリカのデータ複製などの内部オーバーヘッドをカバーするために追加容量が確保されているためです。
トピックに必要なパーティション数を見積もる際は、ビジネスサイドのピーク生成または消費トラフィックのみに基づいて計算してください。1:1 の読み取り/書き込み比率を考慮してパーティション数を 2 倍にする必要はありません。仕様値と基盤となる NIC トラフィックには、すでに複製オーバーヘッドが考慮されているためです。
トラフィック使用量の監視 — 単一ノードのスロットリングまたはトラフィックの偏りを特定するには、インスタンス詳細ページの左側のナビゲーションペインで Prometheus モニタリング に移動します。[ノード消費トラフィック] と [クラスター消費トラフィック] のメトリックを表示して、実際のノードごとのトラフィックをノードごとの制限 (合計仕様 ÷ ノード数) と比較します。
インスタンスのパーティション
パーティション数はインスタンスのエディションによって異なります。詳細については、次の表をご参照ください。
サーバーレスインスタンス
エディション | パーティションレプリカ | 最大パーティションレプリカ数 |
Basic Edition |
|
より高い上限をご希望の場合は、チケットを送信 してください。 |
Standard Edition | ||
Professional Edition |
サブスクリプションおよび従量課金インスタンス
Standard Edition (高書き込み)
トラフィック仕様 | 付属パーティション | 最大パーティション数 |
alikafka.hw.2xlarge | 1,000 | 4,000 |
alikafka.hw.3xlarge | 1,000 | 4,200 |
alikafka.hw.6xlarge | 1,000 | 4,400 |
alikafka.hw.9xlarge | 1,000 | 4,600 |
alikafka.hw.12xlarge | 1,000 | 4,800 |
Professional Edition (高書き込み)
トラフィック仕様 | 付属パーティション | 最大パーティション数 |
alikafka.hw.2xlarge | 1,000 | 4,000 |
alikafka.hw.3xlarge | 1,000 | 4,200 |
alikafka.hw.6xlarge | 1,000 | 4,400 |
alikafka.hw.9xlarge | 1,000 | 4,600 |
alikafka.hw.12xlarge | 1,000 | 4,800 |
alikafka.hw.16xlarge | 2,000 | 5,000 |
alikafka.hw.20xlarge | 2,000 | 6,000 |
alikafka.hw.25xlarge | 2,000 | 7,000 |
alikafka.hw.30xlarge | 2,000 | 8,000 |
alikafka.hw.60xlarge | 2,000 | 9,000 |
alikafka.hw.80xlarge | 2,000 | 10,000 |
alikafka.hw.100xlarge | 3,000 | 12,000 |
alikafka.hw.120xlarge | 3,000 | 14,000 |
alikafka.hw.150xlarge | 3,000 | 16,000 |
alikafka.hw.180xlarge | 3,000 | 18,000 |
alikafka.hw.200xlarge | 3,000 | 20,000 |
alikafka.hw2.220xlarge | 4,000 | 24,000 |
alikafka.hw2.300xlarge | 4,000 | 26,000 |
alikafka.hw2.400xlarge | 4,000 | 28,000 |
alikafka.hw2.500xlarge | 4,000 | 30,000 |
alikafka.hw2.600xlarge | 5,000 | 32,000 |
alikafka.hw2.700xlarge | 5,000 | 34,000 |
alikafka.hw2.800xlarge | 5,000 | 36,000 |
alikafka.hw2.900xlarge | 5,000 | 38,000 |
alikafka.hw2.1000xlarge | 5,000 | 40,000 |
Professional Edition (高読み取り)
トラフィック仕様 | 付属パーティション | 最大パーティション数 |
alikafka.hr.2xlarge | 1,000 | 4,000 |
alikafka.hr.3xlarge | 1,000 | 4,200 |
alikafka.hr.6xlarge | 1,000 | 4,400 |
alikafka.hr.9xlarge | 1,000 | 4,600 |
alikafka.hr.12xlarge | 1,000 | 4,800 |
alikafka.hr.16xlarge | 2,000 | 5,000 |
alikafka.hr.20xlarge | 2,000 | 6,000 |
alikafka.hr.25xlarge | 2,000 | 7,000 |
alikafka.hr.30xlarge | 2,000 | 8,000 |
alikafka.hr.60xlarge | 2,000 | 9,000 |
alikafka.hr.80xlarge | 2,000 | 10,000 |
alikafka.hr.100xlarge | 3,000 | 12,000 |
alikafka.hr.120xlarge | 3,000 | 14,000 |
alikafka.hr.150xlarge | 3,000 | 16,000 |
alikafka.hr.180xlarge | 3,000 | 18,000 |
alikafka.hr.200xlarge | 3,000 | 20,000 |
alikafka.hr2.220xlarge | 4,000 | 24,000 |
alikafka.hr2.300xlarge | 4,000 | 26,000 |
alikafka.hr2.400xlarge | 4,000 | 28,000 |
alikafka.hr2.500xlarge | 4,000 | 30,000 |
alikafka.hr2.600xlarge | 5,000 | 32,000 |
alikafka.hr2.700xlarge | 5,000 | 34,000 |
alikafka.hr2.800xlarge | 5,000 | 36,000 |
alikafka.hr2.900xlarge | 5,000 | 38,000 |
alikafka.hr2.1000xlarge | 5,000 | 40,000 |
よくある質問
Kafka と MQTT ルールエンジンの統合におけるインスタンスエディションの要件
Message Queue for Apache Kafka を MQTT ルールエンジンと併用する場合、必須のエディション要件はありません。Standard Edition、Professional Edition、Serverless Edition のいずれのエディションでも、基本的な統合をサポートしています。
ただし、本番環境で SASL 認証または ACL ベースのアクセス制御が必要な場合は、Professional Edition または Serverless Edition を使用する必要があります。Standard Edition は SASL エンドポイントまたは ACL をサポートしていません。
Professional edition (High-write) のディスク容量の上限
ディスク容量はクラスター単位でプロビジョニングされ、クラスター内のすべてのブローカーノードに均等に割り当てられます。Professional edition (High-write) には、明確な最大ディスク容量の上限はありません。ただし、各トラフィック仕様には対応する最小ディスク容量の要件があるため、選択できるディスク容量は選択したトラフィック仕様によって異なります。
インスタンスを作成する際は、ビジネス要件に合ったディスクサイズを選択してください。インスタンスのディスクタイプとしてウルトラディスクまたは SSD を選択した後は、ディスクタイプを変更できません。
Kafka インスタンスのブローカーノード数と手動設定の可否
ApsaraMQ for Kafka は、Alibaba Cloud が提供するフルマネージドメッセージキューサービスです。システムはインスタンスのトラフィック仕様に基づいて、ブローカーノードの数と構成を自動的に調整します。そのため、個々のノードの詳細を管理する必要はありません。ブローカーノード数を手動で設定または指定することはできません。
Professional edition (High-write) の alikafka.hw.2xlarge 仕様における最大接続数
alikafka.hw.2xlarge トラフィック仕様のインスタンスでは、トラフィック仕様をアップグレードしない場合、ノードあたりの最大接続数の初期値は 1,000 です。ビジネス上、より高い接続制限が必要な場合は、インスタンスのトラフィック仕様をアップグレードしてください。
キーワード：最大接続数、接続制限、alikafka.hw.2xlarge。