Konfigurasikan parameter untuk instans Message Queue for Apache Kafka - Data Transmission Service

Jika instans tujuan dari tugas Data Transmission Service (DTS) adalah instans ApsaraMQ for Kafka yang terhubung melalui Express Connect, VPN Gateway, atau Smart Access Gateway, Anda harus mengonfigurasi serangkaian parameter khusus. Halaman ini menjelaskan setiap parameter dan cara menemukan nilainya.

Catatan penggunaan

Saat instans ApsaraMQ for Kafka terhubung melalui Express Connect, VPN Gateway, atau Smart Access Gateway, DTS menulis data ke node yang ditentukan.
Jika database sumber adalah MySQL, atur parameter Access Method ke Alibaba Cloud Instance untuk instans ApsaraMQ for Kafka tujuan.

Penting

Beberapa tugas DTS tidak mendukung pemilihan langsung ApsaraMQ for Kafka sebagai jenis database. Dalam kasus tersebut, konfigurasikan instans ApsaraMQ for Kafka sebagai cluster Kafka yang dikelola sendiri.

Prasyarat

Sebelum memulai, pastikan Anda telah memiliki:

Instans ApsaraMQ for Kafka yang dapat diakses dari jaringan tugas DTS melalui Express Connect, VPN Gateway, atau Smart Access Gateway
Akses ke Konsol Message Queue for Apache Kafka

Temukan nilai parameter di Konsol Kafka

Sebagian besar nilai parameter berasal dari halaman Instance Details. Untuk membukanya:

Login ke Konsol Message Queue for Apache Kafka.
Pada bilah navigasi atas, pilih wilayah tempat instans tujuan berada.
Di halaman Instances, klik nama instans tujuan.

Parameter

Parameter	Nilai	Tempat menemukannya
Access Method	Pilih Express Connect, VPN Gateway, or Smart Access Gateway.	Tidak berlaku
Connected VPC	ID VPC tempat instans ApsaraMQ for Kafka berada.	Di tab Instance Information, buka bagian Configuration Information dan salin nilai VPC ID.
IP Address or Domain Name	Alamat IP instans ApsaraMQ for Kafka. Masukkan salah satu alamat IP beserta nomor port-nya.	Di tab Instance Information, buka bagian Endpoint Information. Temukan baris dengan Type bernilai Default Endpoint, lalu arahkan kursor ke nama domain untuk melihat IP Address.
Port Number	Port layanan instans ApsaraMQ for Kafka. Default: `9092`.	Tidak berlaku
Database Account	Username SASL yang digunakan untuk mengakses instans tujuan. Hanya diperlukan jika fitur daftar kontrol akses (ACL) diaktifkan. Untuk informasi lebih lanjut tentang cara mengaktifkan ACL, lihat Berikan izin kepada pengguna SASL.	Di tab Manage SASL Users, lihat kolom Username.
Database Password	Password untuk akun database di atas. Hanya diperlukan jika ACL diaktifkan. Bidang ini dan Database Account harus diisi bersamaan — biarkan keduanya kosong jika ACL dinonaktifkan.	Di tab Manage SASL Users, temukan akun tersebut dan klik Copy Password.
Kafka Version	Pilih berdasarkan versi utama instans Anda: Versi instans 0.10.2 → pilih 0.10 Versi instans 2.6.2 atau 2.2.0 → pilih Later Than 1.0	Di tab Instance Information, buka bagian Basic Information dan periksa bidang Major Version.
Encryption	Pilih berdasarkan konfigurasi ACL Anda: ACL disabled → pilih Non-encrypted ACL diaktifkan dan User Type bernilai SCRAM → pilih SCRAM-SHA-256 ACL diaktifkan dan User Type bukan SCRAM → pilih Non-encrypted	Di tab Manage SASL Users, periksa kolom User Type. Tab ini hanya muncul jika ACL diaktifkan.