ApsaraMQ for Kafka:VPC 経由で ApsaraMQ for Kafka に接続

手順 1：インスタンスの作成

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

2. ページ右側の [Quick Start] セクションで、[Create Instance] をクリックします。

3. 表示されるパネルで、[Instance Series] と課金モデルを選択します：

   課金モデル	ユースケース
   従量課金	開発、テスト、またはトラフィックが変動するワークロードに適しています。
   サブスクリプション	利用量とコストを予測しやすい本番環境に適しています。
   サーバーレス	実際の使用量に基づいて課金され、自動で弾力的にスケールします。

   [OK] をクリックします。

4. 購入ページで、インスタンスのパラメータを設定します：

   パラメータ	説明
   インスタンスタイプ	Standard (High-write) は、ほとんどのユースケースに適しています。
   [Region]	レイテンシを最小化するために、アプリケーションサーバーと同じリージョンに合わせます。
   ネットワークタイプ	[VPC instance] を選択します。
   トラフィック仕様	想定スループットに基づいて選択します。たとえば、alikafka.hw.2xlarge は 20 MB/s の読み書きをサポートします。
   ディスクタイプ	[Ultra Disk] は一般的なワークロードに適しています。高いスループットが必要な場合や、メッセージのバックログが大きい場合は [SSD] を使用します。
   ディスク容量	保持期間に基づいて容量を決めます。推奨：300～900 GB。

5. [Buy Now] をクリックし、支払いを完了します。

購入後、[Instances] ページに、インスタンスが [Not Deployed] 状態で表示されます。

手順 2：VPC 情報の取得

インスタンスをデプロイする前に、VPC と vSwitch の ID を取得します。

1. Virtual Private Cloud コンソール にログインします。

2. 左側のナビゲーションペインで、[vSwitches] をクリックします。

3. 上部メニューで、ターゲットリージョンを選択します。

4. [vSwitches] ページで、次の情報を記録します：

   • vSwitch ID：[Instance ID/name] 列で確認します。

   • VPC ID：[Virtual private cloud] 列で確認します。

VPC がない場合：すばやく作成

1. Virtual Private Cloud コンソールで、[Create VPC] をクリックします。

2. 名前を入力し、192.168.0.0/16 などの IPv4 CIDR ブロックを設定します。

3. VPC の作成時に vSwitch を追加します。アベイラビリティーゾーンを選択し、192.168.0.0/24 などのサブネット CIDR ブロックを設定します。

手順 3：インスタンスのデプロイ

1. ApsaraMQ for Kafka コンソール で、[Not Deployed] のインスタンスを [Instances] ページで見つけます。

2. [操作] 列で、[Deploy] をクリックします。

3. [Deploy Instance] パネルで、次のパラメータを設定します：

   パラメータ	説明
   VPC ID	手順 2 で取得した VPC を選択します。
   vSwitch ID	手順 2 で取得した vSwitch を選択します。
   [Version]	2.6.2 (推奨) または 2.2.0 を選択します。
   メッセージ保持期間	メッセージを保持する期間です。デフォルト：72 時間。
   最大メッセージサイズ	メッセージ 1 件あたりの最大サイズです。デフォルト：1 MB。
   コンシューマーオフセット保持期間	コンシューマーオフセットを保持する期間です。デフォルト：10,080 分 (7 日)。
   ディスク暗号化	保管時の暗号化が必要な場合は、この設定を有効にします。

   Professional Edition のみ：

   • クロスゾーンデプロイ：ディザスタリカバリのために、インスタンスをアベイラビリティーゾーンに分散します。

   • ACL 機能：SASL 認証によるアクセス制御を有効にします。

4. [OK] をクリックします。

手順 4：インスタンスのエンドポイントの取得

インスタンスが稼働した後：

1. [Instances] ページでインスタンス名をクリックし、[Instance Details] ページを開きます。

2. [Endpoint information] セクションで、インスタンスのエンドポイントを確認します。

   タイプ	ネットワーク	プロトコル	ユースケース
   デフォルトエンドポイント	VPC	PLAINTEXT	VPC 内からのアクセス

   エンドポイント形式の例：

   alikafka-pre-public-intl-sg-xxxxx-1-vpc.alikafka.aliyuncs.com:9092,
   alikafka-pre-public-intl-sg-xxxxx-2-vpc.alikafka.aliyuncs.com:9092,
   alikafka-pre-public-intl-sg-xxxxx-3-vpc.alikafka.aliyuncs.com:9092

3. エンドポイントをコピーし、Kafka クライアントの bootstrap.servers の値として設定します。

手順 5：エンドポイントのホワイトリストの設定

デフォルトでは、同一 vSwitch 内のクライアントのみが接続できます。ほかの VPC サブネットからのアクセスを許可するには、ホワイトリストを設定します。

1. [Endpoint information] でエンドポイントを見つけ、[操作] 列で [Manage Whitelist] をクリックします。

2. [Whitelist Management] ページで、[Add Whitelist Group] をクリックします。

3. ホワイトリストグループを設定します：

   • [Group name]： app-servers などの名前を入力します。

   • [IP addresses in group]：許可する IP アドレスまたは CIDR ブロックを入力します。

4. OK をクリックします。

ネットワーク接続性の確認

VPC 内のサーバーから次のコマンドを実行します：

telnet alikafka-pre-public-intl-sg-xxxxx-1-vpc.alikafka.aliyuncs.com 9092

接続に成功すれば、ネットワーク設定が正しいことを確認できます。