このガイドでは、お使いの Virtual Private Cloud (VPC) 内からアクセス可能な Kafka インスタンスを設定する手順を説明します。このガイドを最後まで進めると、アプリケーションですぐに利用できるエンドポイントを持つ、実行中の Kafka インスタンスが完成します。
事前準備
以下をご確認ください:
ApsaraMQ for Kafka に必要な権限を持つ Alibaba Cloud アカウント
ターゲットリージョンに VPC と vSwitch があること (または、設定中に作成することもできます)
Kafka インスタンスを初めてデプロイすると、コンソールにサービスリンクロール (AliyunServiceRoleForAlikafka) の承認を求めるプロンプトが表示されます。[OK] をクリックして続行してください。この承認は、サービスがお客様に代わってリソースを管理するために必要です。
ステップ 1: Kafka インスタンスの作成
ApsaraMQ for Kafka コンソールを開きます。
[インスタンスの購入] をクリックします。
課金モデルを選択します:
従量課金 (時間単位) – 開発、テスト、または変動のあるワークロードに最適です
サブスクリプション – 使用量が予測可能な本番環境でコスト効率に優れています
サーバーレス – 使用量に応じて支払う自動スケーリングオプションです
インスタンスを設定します:
設定
推奨
インスタンスエディション
ほとんどのワークロードには Standard Edition (高書き込み)
リージョン
アプリケーションサーバと同じリージョンを選択します
インスタンスタイプ
プライベートネットワークアクセスには、[VPC] を選択します
トラフィック仕様
予測されるスループットに一致させます (例: 20 MB/s の読み取り/書き込みには
alikafka.hw.2xlarge)ディスクタイプ
汎用にはウルトラディスク、高スループットまたはメッセージバックログのシナリオには SSD
ディスク容量
保持期間のニーズに基づき、300~900 GB から開始します
[今すぐ購入] をクリックし、支払いを完了します。
インスタンスリストに、インスタンスが [未デプロイ] のステータスで表示されます。
ステップ 2: VPC 情報の取得
デプロイする前に、VPC ID と vSwitch ID が必要です。まだ VPC がない場合は、ここで作成してください。
VPC コンソールを開きます。
左側のナビゲーションで [vSwitch] に移動します。
上部のメニューからターゲットリージョンを選択します。
以下をメモします:
vSwitch ID – [インスタンス ID/名前] 列に記載されています
VPC ID – [VPC] 列に記載されています
vSwitch によって、Kafka インスタンスがデプロイされるアベイラビリティゾーンが決まります。レイテンシーを最小限に抑えるために、アプリケーションサーバに近いゾーンを選択してください。
VPC の作成 (必要な場合)
VPC コンソールで、[VPC の作成] をクリックします。
名前と IPv4 CIDR ブロック (例:
192.168.0.0/16) を設定します。任意のゾーンにサブネットを指定して vSwitch を作成します (例:
192.168.0.0/24)。
ステップ 3: インスタンスのデプロイ
Kafka コンソールに戻り、ステータスが [未デプロイ] のインスタンスを見つけます。
「アクション」列の[デプロイ]をクリックします。
デプロイメントを設定します:
設定
説明
VPC ID
ステップ 2 の VPC を選択します
vSwitch ID
ステップ 2 の vSwitch を選択します
バージョン
2.6.2(推奨) または2.2.0を選択しますメッセージ保持期間
メッセージが保持される期間 (デフォルト:72 時間)
最大メッセージサイズ
許可される最大メッセージサイズ (デフォルト:1 MB)
コンシューマオフセット保持期間
コンシューマオフセットが保存される期間 (デフォルト:10,080 分/7 日間)
ディスク暗号化
保存時の暗号化が必要な場合に有効化します
Professional Edition のみ:
クロスゾーンデプロイメント – 可用性を高めるために複数のゾーンにまたがってデプロイします
ACL – SASL 認証のためのアクセスの制御を有効にします
[OK] をクリックしてデプロイメントを開始します。
デプロイには 10~30 分かかります。完了すると、ステータスが [デプロイ中] から [実行中] に変わります。
ステップ 4: 接続エンドポイントの取得
インスタンスが実行中になったら、次の手順に進みます:
インスタンス名をクリックして [インスタンス詳細] を開きます。
[エンドポイント情報] セクションまでスクロールします。
接続エンドポイントが表示されます:
タイプ
ネットワーク
プロトコル
ユースケース
デフォルトエンドポイント
VPC
PLAINTEXT
VPC 内からの標準的な接続
エンドポイントは次のようになります:
alikafka-post-public-intl-sg-xxxxx-1-vpc.alikafka.aliyuncs.com:9092, alikafka-post-public-intl-sg-xxxxx-2-vpc.alikafka.aliyuncs.com:9092, alikafka-post-public-intl-sg-xxxxx-3-vpc.alikafka.aliyuncs.com:9092エンドポイントをコピーして、お使いの Kafka クライアント構成の
bootstrap.serversとして使用します。
ステップ 5: ホワイトリストの設定
デフォルトでは、同じ vSwitch 内のクライアントのみが接続できます。VPC の他の部分からの接続を許可するには、次の手順を実行します:
[エンドポイント情報] セクションで、「操作」列の [ホワイトリストの管理] をクリックします。
[ホワイトリストの作成] をクリックします。
ホワイトリストを設定します:
名前:わかりやすい名前 (例:
app-servers)IP アドレス:CIDR ブロックまたは特定の IP を入力します
[OK] をクリックします。
接続性の確認
VPC 内のサーバーから、接続をテストします:
telnet alikafka-post-public-intl-sg-xxxxx-1-vpc.alikafka.aliyuncs.com 9092接続に成功すると、ネットワーク設定が正しいことが確認できます。
クイックリファレンス: インスタンス設定
デプロイされたインスタンスの主要な設定の概要を以下に示します。これらは **[インスタンス詳細]** で確認できます:
プロパティ | 場所 |
インスタンス ID | 基本情報 |
ステータス | 基本情報 |
VPC/vSwitch | 設定情報 |
エンドポイント | エンドポイント情報 |
Topic/グループ/パーティションのクォータ | 設定情報 |
メッセージ設定 | 設定情報 |
次のステップ
これで Kafka インスタンスの準備が整いました。一般的な次のステップは以下の通りです: