Topik ini menjelaskan cara memigrasikan data dari database TiDB ke cluster AnalyticDB for MySQL V3.0 menggunakan Data Transmission Service (DTS).
Prasyarat
Cluster AnalyticDB for MySQL V3.0 tujuan telah dibuat. Ruang penyimpanan yang tersedia di cluster ini lebih besar daripada total ukuran data di database TiDB sumber. Untuk informasi lebih lanjut, lihat Buat Cluster.
Persiapan (opsional) dilakukan untuk mengumpulkan data tambahan jika Anda ingin memigrasikan data tambahan dari database TiDB.
Persiapan (opsional)
Anda dapat menggunakan salah satu metode berikut untuk mengumpulkan data tambahan dari database TiDB:
Gunakan TiDB Binlog
Server tempat database sumber ditempatkan harus berada di jaringan internal yang sama dengan server tempat Pump, Drainer, dan cluster Kafka ditempatkan. Ini meminimalkan dampak latensi jaringan pada migrasi data tambahan.
Siapkan cluster atau instance Kafka menggunakan salah satu metode berikut.
Deploy cluster Kafka yang dikelola sendiri. Untuk informasi lebih lanjut, kunjungi Situs Resmi Apache Kafka.
PeringatanKami merekomendasikan menyetel parameter
message.max.bytesdanreplica.fetch.max.bytesuntuk broker Kafka serta parameterfetch.message.max.bytesuntuk konsumen Kafka ke nilai yang lebih tinggi. Ini memastikan bahwa cluster Kafka dapat menerima jumlah data log biner yang lebih besar dari database TiDB. Untuk informasi lebih lanjut, lihat KONFIGURASI.Buat instance ApsaraMQ for Kafka. Untuk informasi lebih lanjut, lihat Ikhtisar.
CatatanInstance ApsaraMQ for Kafka harus ditempatkan di virtual private cloud (VPC) yang sama dengan server database sumber. Ini memastikan transmisi data yang andal dan meminimalkan dampak latensi jaringan pada migrasi data tambahan.
Buat topik di cluster Kafka yang dikelola sendiri atau instance ApsaraMQ for Kafka.
PentingUntuk memastikan bahwa data tambahan dapat direplikasi ke partisi dengan ID 0, pastikan bahwa topik hanya berisi satu partisi.
Deploy Pump dan Drainer. Untuk informasi lebih lanjut, lihat Penerapan Cluster TiDB Binlog.
Ubah file konfigurasi Drainer dan tentukan cluster Kafka untuk menerima data dari Drainer. Untuk informasi lebih lanjut, lihat Panduan Pengguna Klien Konsumen Binlog.
CatatanPastikan bahwa server tempat database TiDB ditempatkan dapat terhubung ke cluster Kafka.
Tambahkan blok CIDR server DTS ke daftar putih database TiDB. Untuk informasi lebih lanjut, lihat Tambahkan Blok CIDR Server DTS.
Gunakan TiCDC
Siapkan cluster atau instance Kafka menggunakan salah satu metode berikut.
Deploy cluster Kafka yang dikelola sendiri. Untuk informasi lebih lanjut, kunjungi Situs Resmi Apache Kafka.
PeringatanKami merekomendasikan menyetel parameter
message.max.bytesdanreplica.fetch.max.bytesuntuk broker Kafka serta parameterfetch.message.max.bytesuntuk konsumen Kafka ke nilai yang lebih tinggi. Ini memastikan bahwa cluster Kafka dapat menerima jumlah data log biner yang lebih besar dari database TiDB. Untuk informasi lebih lanjut, lihat KONFIGURASI.Buat instance ApsaraMQ for Kafka. Untuk informasi lebih lanjut, lihat Ikhtisar.
CatatanInstance ApsaraMQ for Kafka harus ditempatkan di virtual private cloud (VPC) yang sama dengan server database sumber. Ini memastikan transmisi data yang andal dan meminimalkan dampak latensi jaringan pada migrasi data tambahan.
Buat topik di cluster Kafka yang dikelola sendiri atau instance ApsaraMQ for Kafka.
PentingUntuk memastikan bahwa data tambahan dapat direplikasi ke partisi dengan ID 0, pastikan bahwa topik hanya berisi satu partisi.
Instal TiCDC. Untuk informasi lebih lanjut, lihat Deploy dan Maintain TiCDC.
CatatanKami merekomendasikan menggunakan TiUP untuk menambahkan node TiCDC baru atau meningkatkan node TiCDC yang ada di cluster TiDB.
Replikasikan data tambahan di database TiDB sumber ke Kafka. Untuk informasi lebih lanjut, lihat Replikasi Data ke Kafka.
CatatanPastikan bahwa server tempat database TiDB ditempatkan dapat terhubung ke cluster Kafka.
Kami merekomendasikan menggunakan
tiup cdc cli changefeed create \di baris perintah pertama.
Catatan penggunaan
Kategori | Deskripsi |
Batasan pada database sumber |
|
Batasan lainnya |
|
Pemetaan tipe data
Untuk informasi lebih lanjut, lihat Pemetaan Tipe Data antara Database Heterogen.
Penagihan
Jenis migrasi | Biaya konfigurasi instance | Biaya lalu lintas internet |
Migrasi skema dan migrasi data penuh | Gratis. | Ketika parameter Access Method database tujuan disetel ke Public IP Address, Anda akan dikenakan biaya untuk lalu lintas internet. Untuk informasi lebih lanjut, lihat Ikhtisar Penagihan. |
Migrasi data tambahan | Dikenakan biaya. Untuk informasi lebih lanjut, lihat Ikhtisar Penagihan. |
Operasi SQL yang mendukung migrasi tambahan
Jenis operasi | Pernyataan SQL |
DML | INSERT, UPDATE, dan DELETE Catatan Ketika data ditulis ke cluster AnalyticDB for MySQL V3.0 tujuan, pernyataan UPDATE secara otomatis diubah menjadi pernyataan REPLACE INTO. Jika pernyataan UPDATE dieksekusi pada kunci utama, pernyataan UPDATE diubah menjadi pernyataan DELETE dan INSERT. |
DDL | CREATE TABLE, DROP TABLE, RENAME TABLE, TRUNCATE TABLE, ADD COLUMN, dan DROP COLUMN |
Izin yang diperlukan untuk akun database
Database | Izin yang diperlukan | Referensi |
Database TiDB | Izin SELECT pada objek yang akan dimigrasikan dan izin SHOW VIEW | Privilege Management |
AnalyticDB for MySQL Kluster V3.0 | Hak baca dan tulis pada database tujuan |
Prosedur
Gunakan salah satu metode berikut untuk pergi ke halaman Migrasi Data dan pilih wilayah tempat instance migrasi data berada.
Konsol DTS
Masuk ke Konsol DTS.
Di bilah navigasi di sebelah kiri, klik Data Migration.
Di sudut kiri atas halaman, pilih wilayah tempat instance migrasi data berada.
Konsol DMS
CatatanOperasi aktual mungkin berbeda berdasarkan mode dan tata letak konsol DMS. Untuk informasi lebih lanjut, lihat Mode Sederhana dan Sesuaikan Tata Letak dan Gaya Konsol DMS.
Masuk ke Konsol DMS.
Di bilah navigasi atas, gerakkan penunjuk mouse ke .
Dari daftar drop-down di sebelah kanan Data Migration Tasks, pilih wilayah tempat instance sinkronisasi data berada.
Klik Create Task untuk pergi ke halaman konfigurasi tugas.
Konfigurasikan database sumber dan tujuan. Tabel berikut menjelaskan parameter.
Bagian
Parameter
Deskripsi
Tidak ada
Task Name
Nama tugas DTS. DTS secara otomatis menghasilkan nama tugas. Kami merekomendasikan Anda menentukan nama deskriptif yang memudahkan identifikasi tugas. Anda tidak perlu menentukan nama tugas yang unik.
Source Database
Select Existing Connection
Jika Anda menggunakan instance database yang terdaftar dengan DTS, pilih instance dari daftar drop-down. DTS secara otomatis mengisi parameter database berikut untuk instance tersebut. Untuk informasi lebih lanjut, lihat Kelola koneksi database.
CatatanDi konsol DMS, Anda dapat memilih instance database dari daftar drop-down Select a DMS database instance.
Jika Anda gagal mendaftarkan instance dengan DTS, atau Anda tidak perlu menggunakan instance yang terdaftar dengan DTS, Anda harus mengonfigurasi informasi database berikut.
Database Type
Tipe database sumber. Pilih TiDB.
Access Method
Metode akses database sumber. Pilih metode akses berdasarkan lokasi penyebaran database TiDB. Dalam contoh ini, pilih Self-managed Database on ECS.
CatatanJika Anda menyetel parameter ini ke nilai lain, Anda harus menyiapkan lingkungan yang diperlukan untuk database yang dikelola sendiri sebelum migrasi data. Untuk informasi lebih lanjut, lihat Ikhtisar Persiapan.
Instance Region
Wilayah tempat database TiDB berada.
ECS Instance ID
ID instance ECS yang menyimpan database TiDB.
Port Number
Nomor port layanan database TiDB. Nilai default: 4000.
Database Account
Akun database TiDB.
Database Password
Kata sandi yang digunakan untuk mengakses database.
Migrate Incremental Data
Menentukan apakah akan memigrasikan data tambahan dari database TiDB. Konfigurasikan parameter ini berdasarkan kebutuhan bisnis Anda.
CatatanJika Anda ingin memigrasikan data tambahan dari database TiDB, pilih Yes dan masukkan Cluster Kafka.
Destination Database
Select Existing Connection
Jika Anda menggunakan instance database yang terdaftar dengan DTS, pilih instance dari daftar drop-down. DTS secara otomatis mengisi parameter database berikut untuk instance tersebut. Untuk informasi lebih lanjut, lihat Kelola koneksi database.
CatatanDi konsol DMS, Anda dapat memilih instance database dari daftar drop-down Select a DMS database instance.
Jika Anda gagal mendaftarkan instance dengan DTS, atau Anda tidak perlu menggunakan instance yang terdaftar dengan DTS, Anda harus mengonfigurasi informasi database berikut.
Database Type
Tipe database tujuan. Pilih AnalyticDB for MySQL 3.0.
Access Method
Metode akses database tujuan. Pilih Alibaba Cloud Instance.
Instance Region
Wilayah tempat cluster AnalyticDB for MySQL V3.0 tujuan berada.
Instance ID
ID cluster AnalyticDB for MySQL V3.0 tujuan.
Database Account
Akun database cluster AnalyticDB for MySQL V3.0 tujuan. Untuk informasi lebih lanjut tentang izin yang diperlukan untuk akun tersebut, lihat bagian Persyaratan izin untuk akun database dari topik ini.
Database Password
Kata sandi yang digunakan untuk mengakses instance database.
Di bagian bawah halaman, klik Test Connectivity and Proceed, lalu klik Test Connectivity di kotak dialog CIDR Blocks of DTS Servers yang muncul.
CatatanPastikan bahwa blok CIDR server DTS dapat ditambahkan secara otomatis atau manual ke pengaturan keamanan database sumber dan tujuan untuk mengizinkan akses dari server DTS. Untuk informasi lebih lanjut, lihat Tambahkan Blok CIDR Server DTS.
Konfigurasikan objek yang akan dimigrasikan.
Di halaman Configure Objects, konfigurasikan objek yang akan dimigrasikan.
Parameter
Deskripsi
Migration Types
Untuk hanya melakukan migrasi data penuh, pilih Schema Migration dan Full Data Migration.
Untuk memastikan kontinuitas layanan selama migrasi data, pilih Schema Migration, Full Data Migration, dan Incremental Data Migration.
CatatanJika Anda tidak memilih Schema Migration, pastikan database dan tabel dibuat di database tujuan untuk menerima data dan fitur pemetaan nama objek diaktifkan di Selected Objects.
Jika Anda tidak memilih Incremental Data Migration, kami merekomendasikan Anda untuk tidak menulis data ke database sumber selama migrasi data. Ini memastikan konsistensi data antara database sumber dan tujuan.
Merge Tables
Yes: Jika Anda memilih nilai ini, DTS menambahkan kolom
__dts_data_sourceke setiap tabel untuk mencatat sumber data. Untuk informasi lebih lanjut, lihat Aktifkan fitur penggabungan multi-tabel.No: Ini merupakan nilai default.
CatatanJika Anda menyetel parameter ini ke Ya, semua tabel sumber yang dipilih dalam tugas digabungkan menjadi satu tabel tujuan. Jika Anda tidak perlu menggabungkan tabel sumber tertentu, Anda dapat membuat tugas migrasi data terpisah untuk tabel-tabel tersebut.
PeringatanKami merekomendasikan Anda untuk tidak melakukan operasi DDL untuk mengubah skema database atau tabel sumber. Jika tidak, ketidaksesuaian data mungkin terjadi atau tugas migrasi data mungkin gagal.
Processing Mode of Conflicting Tables
Precheck and Report Errors: memeriksa apakah database tujuan berisi tabel yang menggunakan nama yang sama dengan tabel di database sumber. Jika database sumber dan tujuan tidak berisi tabel dengan nama tabel yang identik, pemeriksaan awal berhasil. Jika tidak, kesalahan dilaporkan selama pemeriksaan awal dan tugas migrasi data tidak dapat dimulai.
CatatanJika database sumber dan tujuan berisi tabel dengan nama yang identik dan tabel di database tujuan tidak dapat dihapus atau diganti namanya, Anda dapat menggunakan fitur pemetaan nama objek untuk mengganti nama tabel yang dimigrasikan ke database tujuan. Untuk informasi lebih lanjut, lihat Peta nama objek.
Ignore Errors and Proceed: melewati pemeriksaan awal untuk nama tabel identik di database sumber dan tujuan.
PeringatanJika Anda memilih Ignore Errors and Proceed, ketidaksesuaian data mungkin terjadi dan bisnis Anda mungkin terpapar risiko potensial berikut:
Jika database sumber dan tujuan memiliki skema yang sama, dan catatan data memiliki kunci utama yang sama dengan catatan data yang ada di database tujuan, skenario berikut mungkin terjadi:
Selama migrasi data penuh, DTS tidak memigrasikan catatan data ke database tujuan. Catatan data yang ada di database tujuan dipertahankan.
Selama migrasi data tambahan, DTS memigrasikan catatan data ke database tujuan. Catatan data yang ada di database tujuan ditimpa.
Jika database sumber dan tujuan memiliki skema yang berbeda, hanya kolom tertentu yang dimigrasikan atau tugas migrasi data gagal. Lanjutkan dengan hati-hati.
Capitalization of Object Names in Destination Instance
Huruf besar/kecil nama database, nama tabel, dan nama kolom di instance tujuan. Secara default, DTS default policy dipilih. Anda dapat memilih opsi lain untuk memastikan huruf besar/kecil nama objek konsisten dengan database sumber atau tujuan. Untuk informasi lebih lanjut, lihat Tentukan huruf besar/kecil nama objek di instance tujuan.
Source Objects
Pilih satu atau lebih objek dari bagian Source Objects. Klik ikon
untuk menambahkan objek ke bagian Selected Objects. CatatanAnda dapat memilih tabel atau database sebagai objek yang akan dimigrasikan.
Selected Objects
Untuk mengganti nama objek yang ingin Anda migrasikan ke instance tujuan, klik kanan objek di bagian Selected Objects. Untuk informasi lebih lanjut, lihat Peta nama objek tunggal.
Untuk mengganti nama beberapa objek sekaligus, klik Batch Edit di sudut kanan atas bagian Selected Objects. Untuk informasi lebih lanjut, lihat Peta beberapa nama objek sekaligus.
CatatanUntuk menentukan kondisi WHERE untuk memfilter data, klik kanan tabel di bagian Selected Objects. Di kotak dialog yang muncul, Tentukan kondisi filter.
Jika Anda menggunakan fitur pemetaan nama objek untuk mengganti nama objek, objek lain yang bergantung pada objek tersebut mungkin gagal dimigrasikan.
Klik Next: Advanced Settings untuk mengonfigurasi pengaturan lanjutan.
Parameter
Deskripsi
Retry Time for Failed Connections
Rentang waktu coba ulang untuk koneksi gagal. Jika database sumber atau tujuan gagal terhubung setelah tugas migrasi data dimulai, DTS segera mencoba menghubungkan kembali dalam rentang waktu coba ulang. Nilai valid: 10 hingga 1.440. Unit: menit. Nilai default: 720. Kami merekomendasikan menyetel parameter ini ke nilai lebih besar dari 30. Jika DTS berhasil tersambung kembali ke database sumber dan tujuan dalam rentang waktu coba ulang yang ditentukan, DTS melanjutkan tugas migrasi data. Jika tidak, tugas migrasi data gagal.
CatatanJika Anda menentukan rentang waktu coba ulang berbeda untuk beberapa tugas migrasi data yang berbagi database sumber atau tujuan yang sama, nilai yang ditentukan terakhir akan diutamakan.
Saat DTS mencoba menghubungkan kembali, Anda akan dikenakan biaya untuk instance DTS. Kami merekomendasikan menentukan rentang waktu coba ulang berdasarkan kebutuhan bisnis Anda. Anda juga dapat melepaskan instance DTS sesegera mungkin setelah instance database sumber dan tujuan dilepaskan.
Retry Time for Other Issues
Rentang waktu coba ulang untuk masalah lainnya. Misalnya, jika operasi DDL atau DML gagal dilakukan setelah tugas migrasi data dimulai, DTS segera mencoba kembali operasi tersebut dalam rentang waktu coba ulang. Nilai valid: 1 hingga 1440. Unit: menit. Nilai default: 10. Kami merekomendasikan menyetel parameter ini ke nilai lebih besar dari 10. Jika operasi yang gagal berhasil dilakukan dalam rentang waktu coba ulang yang ditentukan, DTS melanjutkan tugas migrasi data. Jika tidak, tugas migrasi data gagal.
PentingNilai parameter Retry Time for Other Issues harus lebih kecil dari nilai parameter Retry Time for Failed Connections.
Enable Throttling for Full Data Migration
Menentukan apakah akan mengaktifkan pembatasan untuk migrasi data penuh. Selama migrasi data penuh, DTS menggunakan sumber daya baca dan tulis database sumber dan tujuan. Ini dapat meningkatkan beban server database. Anda dapat mengaktifkan pembatasan untuk migrasi data penuh berdasarkan kebutuhan bisnis Anda. Untuk mengonfigurasi pembatasan, Anda harus mengonfigurasi parameter Queries per second (QPS) to the source database, RPS of Full Data Migration, dan Data migration speed for full migration (MB/s). Ini mengurangi beban server database tujuan.
CatatanAnda hanya dapat mengonfigurasi parameter ini jika Anda memilih Full Data Migration untuk parameter Migration Types.
Enable Throttling for Incremental Data Migration
Menentukan apakah akan mengaktifkan pembatasan untuk migrasi data tambahan. Untuk mengonfigurasi pembatasan, Anda harus mengonfigurasi parameter RPS of Incremental Data Migration dan Data migration speed for incremental migration (MB/s). Ini mengurangi beban server database tujuan.
CatatanAnda hanya dapat mengonfigurasi parameter ini jika Anda memilih Incremental Data Migration untuk parameter Migration Types.
Environment Tag
Tag lingkungan yang digunakan untuk mengidentifikasi instance DTS. Anda dapat memilih tag lingkungan berdasarkan kebutuhan bisnis Anda. Dalam contoh ini, Anda tidak perlu mengonfigurasi parameter ini.
Configure ETL
Menentukan apakah akan mengaktifkan fitur ekstraksi, transformasi, dan pemuatan (ETL). Untuk informasi lebih lanjut, lihat Apa itu ETL? Nilai valid:
Yes: mengonfigurasi fitur ETL. Anda dapat memasukkan pernyataan pemrosesan data di editor kode. Untuk informasi lebih lanjut, lihat Configure ETL in a data migration or data synchronization task.
No: Fitur ETL tidak dikonfigurasi.
Monitoring and Alerting
Menentukan apakah akan mengonfigurasi peringatan untuk tugas migrasi data. Jika tugas gagal atau latensi migrasi melebihi ambang batas yang ditentukan, kontak peringatan menerima notifikasi. Nilai valid:
No: tidak mengonfigurasi peringatan.
Yes: mengonfigurasi peringatan. Dalam hal ini, Anda juga harus mengonfigurasi ambang batas peringatan dan pengaturan notifikasi peringatan. Untuk informasi lebih lanjut, lihat bagian Konfigurasikan Pemantauan dan Peringatan saat Membuat Tugas DTS dari topik Konfigurasikan Pemantauan dan Peringatan.
Klik Next Step: Data Verification untuk mengonfigurasi tugas verifikasi data.
Untuk informasi lebih lanjut tentang cara menggunakan fitur verifikasi data, lihat Konfigurasikan Tugas Verifikasi Data.
Opsional. Klik Next: Configure Database and Table Fields. Di halaman yang muncul, konfigurasikan Type, Primary Key Column, Distribution Key, dan informasi kunci partisi seperti Partition Key, Partitioning Rules dan Partition Lifecycle untuk tabel yang ingin Anda migrasikan ke cluster AnalyticDB for MySQL V3.0 tujuan.
CatatanLangkah ini hanya tersedia jika Anda memilih Schema Migration untuk Migration Types saat Anda mengonfigurasi objek yang akan dimigrasikan dalam tugas. Anda dapat menyetel Definition Status ke All dan memodifikasi bidang database dan tabel.
Di bidang Primary Key Column, Anda dapat menentukan beberapa kolom untuk membentuk kunci primer komposit. Dalam hal ini, Anda harus menentukan satu atau lebih Primary Key Column sebagai Distribution Key dan Partition Key. Untuk informasi lebih lanjut, lihat CREATE TABLE.
Simpan pengaturan tugas dan jalankan pemeriksaan awal.
Untuk melihat parameter yang harus ditentukan saat Anda memanggil operasi API terkait untuk mengonfigurasi tugas DTS, gerakkan penunjuk mouse ke Next: Save Task Settings and Precheck dan klik Preview OpenAPI parameters.
Jika Anda tidak perlu melihat atau telah melihat parameter, klik Next: Save Task Settings and Precheck di bagian bawah halaman.
CatatanSebelum Anda dapat memulai tugas migrasi data, DTS melakukan pemeriksaan awal. Anda hanya dapat memulai tugas migrasi data setelah tugas lulus pemeriksaan awal.
Jika tugas gagal lulus pemeriksaan awal, klik View Details di sebelah setiap item yang gagal. Setelah Anda menganalisis penyebab berdasarkan hasil pemeriksaan, atasi masalah tersebut. Kemudian, jalankan pemeriksaan awal lagi.
Jika peringatan dipicu untuk suatu item selama pemeriksaan awal:
Jika item peringatan tidak dapat diabaikan, klik View Details di sebelah item yang gagal dan atasi masalah tersebut. Kemudian, jalankan pemeriksaan awal lagi.
Jika item peringatan dapat diabaikan, klik Confirm Alert Details. Di kotak dialog Lihat Detail, klik Ignore. Di pesan yang muncul, klik OK. Kemudian, klik Precheck Again untuk menjalankan pemeriksaan awal lagi. Jika Anda mengabaikan item peringatan, ketidaksesuaian data mungkin terjadi, dan bisnis Anda mungkin terpapar risiko potensial.
Beli instance.
Tunggu hingga Success Rate menjadi 100%. Kemudian, klik Next: Purchase Instance.
Di halaman Purchase Instance, konfigurasikan parameter Kelas Instance untuk instance migrasi data. Tabel berikut menjelaskan parameter.
Bagian
Parameter
Deskripsi
New Instance Class
Resource Group
Grup sumber daya tempat instance migrasi data termasuk. Nilai default: default resource group. Untuk informasi lebih lanjut, lihat Apa itu Manajemen Sumber Daya?
Instance Class
DTS menyediakan kelas instance yang bervariasi dalam kecepatan migrasi. Anda dapat memilih kelas instance berdasarkan skenario bisnis Anda. Untuk informasi lebih lanjut, lihat Kelas instance instance migrasi data.
Baca dan setujui Data Transmission Service (Pay-as-you-go) Service Terms dengan memilih kotak centang.
Klik Buy and Start. Di pesan yang muncul, klik OK.
Anda dapat melihat kemajuan tugas di halaman Data Migration.
CatatanJika tugas migrasi data tidak dapat digunakan untuk memigrasikan data tambahan, tugas secara otomatis berhenti. Completed ditampilkan di bagian Status .
Jika tugas migrasi data dapat digunakan untuk memigrasikan data tambahan, tugas tidak berhenti secara otomatis. Tugas migrasi data tambahan tidak pernah berhenti atau selesai. Running ditampilkan di bagian Status.
Cluster Kafka
Parameter | Deskripsi |
Kafka Cluster Type | Tipe cluster Kafka. Konfigurasikan parameter ini berdasarkan lokasi penyebaran cluster Kafka. Dalam contoh ini, pilih Self-managed Database on ECS. Catatan Jika Anda memilih Express Connect, VPN Gateway, or Smart Access Gateway, Anda juga harus memilih VPC dari daftar drop-down Connected VPC dan tentukan Domain Name or IP. |
Kafka Data Source Component | Pilih Use the default binlog format of the TiDB database. atau Use the TiCDC Canal-JSON format. berdasarkan persiapan yang Anda buat. |
ECS Instance ID | ID instance ECS tempat cluster Kafka berada. |
Port Number | Port layanan cluster Kafka. |
Kafka Cluster Account | Nama pengguna dan kata sandi cluster Kafka. Jika otentikasi tidak diaktifkan untuk cluster Kafka, Anda tidak perlu mengonfigurasi parameter ini. |
Kafka Cluster Password | |
Kafka Version | Versi cluster Kafka. Catatan Jika versi cluster Kafka adalah 1.0 atau lebih baru, pilih 1.0. |
Encryption | Menentukan apakah akan mengenkripsi koneksi ke cluster Kafka. Pilih Non-encrypted atau SCRAM-SHA-256 berdasarkan kebutuhan bisnis dan keamanan Anda. |
Topic | Topik tempat data tambahan dimiliki. |