DataWorks Data Integration membaca pesan dari topik Kafka dan menuliskannya ke tabel AnalyticDB for MySQL. Sebuah task sinkronisasi batch menghubungkan Kafka Reader ke AnalyticDB for MySQL 3.0 Writer dan dijalankan pada exclusive resource group for Data Integration.
Prasyarat
-
Exclusive resource group for Data Integration yang memenuhi kebutuhan bisnis Anda telah dibeli. Untuk informasi selengkapnya, lihat Buat dan gunakan exclusive resource group for Data Integration.
-
Koneksi jaringan antara exclusive resource group for Data Integration dan sumber data Anda (baik Kafka maupun AnalyticDB for MySQL) telah dibuat. Untuk informasi selengkapnya, lihat Buat koneksi jaringan antara resource group dan sumber data.
Buat task sinkronisasi batch
Untuk mengimpor data dari Kafka ke AnalyticDB for MySQL, konfigurasikan source reader, destination writer, lalu buat task sinkronisasi yang menghubungkan keduanya.
-
Langkah 1: Konfigurasikan Kafka Reader
Konfigurasikan source reader untuk membaca data dari kluster Kafka Anda.
Untuk detail konfigurasi, lihat Kafka Reader.
-
Langkah 2: Konfigurasikan AnalyticDB for MySQL 3.0 Writer
Konfigurasikan destination writer untuk menulis data ke tabel AnalyticDB for MySQL Anda.
Untuk detail konfigurasi, lihat AnalyticDB for MySQL 3.0 Writer.
-
Langkah 3: Buat task sinkronisasi
Gabungkan Kafka Reader dan AnalyticDB for MySQL 3.0 Writer menjadi sebuah task sinkronisasi data. Antarmuka tanpa kode di DataWorks memungkinkan Anda mengonfigurasi sumber, tujuan, dan pemetaan bidang tanpa menulis kode.
Untuk petunjuk langkah demi langkah, lihat Konfigurasikan task sinkronisasi batch menggunakan antarmuka tanpa kode.