Data Transmission Service (DTS) タスクの宛先インスタンスが、Express Connect、VPN Gateway、または Smart Access Gateway 経由で接続される ApsaraMQ for Kafka インスタンスである場合、一連の特殊なパラメーターを設定する必要があります。本ページでは、各パラメーターの内容およびその値の確認方法について説明します。
注意事項
ApsaraMQ for Kafka インスタンスが Express Connect、VPN Gateway、または Smart Access Gateway 経由で接続されている場合、DTS は指定されたノードにデータを書き込みます。
ソースデータベースが MySQL の場合、宛先 ApsaraMQ for Kafka インスタンスに対して、アクセス方法 パラメーターを Alibaba Cloud インスタンス に設定します。
一部の DTS タスクでは、データベースタイプとして ApsaraMQ for Kafka を直接選択できない場合があります。その場合は、ApsaraMQ for Kafka インスタンスを自己管理 Kafka クラスターとして構成してください。
前提条件
開始する前に、以下の条件を満たしていることをご確認ください。
Express Connect、VPN Gateway、または Smart Access Gateway を介して DTS タスクのネットワークからアクセス可能な ApsaraMQ for Kafka インスタンス
Message Queue for Apache Kafka コンソール へのアクセス権限
Kafka コンソールでのパラメーター値の確認方法
ほとんどのパラメーター値は、インスタンスの詳細 ページから取得できます。このページを開くには、以下の手順を実行します。
Message Queue for Apache Kafka コンソール にログインします。
上部のナビゲーションバーから、宛先インスタンスが配置されているリージョンを選択します。
インスタンス ページで、宛先インスタンスの名前をクリックします。
パラメーター
| パラメーター | 値 | 確認方法 |
|---|---|---|
| アクセス方法 | Express Connect、VPN Gateway、または Smart Access Gateway を選択します。 | 該当なし |
| 接続済み VPC | ApsaraMQ for Kafka インスタンスが属する VPC の ID。 | インスタンス情報 タブの 構成情報 セクションより、VPC ID の値をコピーします。 |
| IP アドレスまたはドメイン名 | ApsaraMQ for Kafka インスタンスの IP アドレス。IP アドレスのいずれかとポート番号を入力します。 | インスタンス情報 タブの エンドポイント情報 セクションで、タイプ が デフォルトエンドポイント である行を探し、ドメイン名にマウスカーソルを合わせて表示される IP アドレス を確認します。 |
| ポート番号 | ApsaraMQ for Kafka インスタンスのサービスポート。デフォルト値：9092。 | 該当なし |
| データベースアカウント | 宛先インスタンスへのアクセスに使用する SASL ユーザー名。アクセス制御リスト (ACL) 機能が有効な場合のみ必須です。ACL の有効化方法については、「SASL ユーザーへの権限付与」をご参照ください。 | SASL ユーザーの管理 タブで、ユーザー名 列を確認します。 |
| データベースパスワード | 上記のデータベースアカウントのパスワード。ACL が有効な場合のみ必須です。データベースアカウント と併せて入力する必要があります。ACL が無効な場合は、両方のフィールドを空欄のままにしてください。 | SASL ユーザーの管理 タブで、対象のアカウントを見つけ、パスワードのコピー をクリックします。 |
| Kafka バージョン | インスタンスのメジャーバージョンに基づいて選択します：
| インスタンス情報 タブの 基本情報 セクションより、メジャーバージョン フィールドを確認します。 |
| 暗号化 | ACL の設定に基づいて選択します：
| SASL ユーザーの管理 タブで、ユーザー種別 列を確認します。このタブは ACL が有効な場合にのみ表示されます。 |