このトピックでは、DataWorksを使用してKafkaからAnalyticDB for MySQL data Lakehouse Edition (V3.0) またはData Warehouse Edition (V3.0) にデータをインポートする方法について説明します。
前提条件
ビジネス要件を満たすData Integration専用リソースグループが購入されました。 詳細については、「Data Integrationの排他的リソースグループの作成と使用」をご参照ください。
Data Integration専用リソースグループとデータソース間のネットワーク接続が確立されます。 詳細については、「リソースグループとデータソース間のネットワーク接続の確立」をご参照ください。
手順
ソースデータベースリーダーを設定します。 詳細については、「Kafkaデータソース」をご参照ください。
ターゲットデータベースライターを設定します。 詳細については、「AnalyticDB For MySQL 3.0 Writer」をご参照ください。
データ同期ジョブを設定します。 詳細については、「コードレスUIを使用したバッチ同期タスクの設定」をご参照ください。