All Products
Search
Document Center

Data Transmission Service:Konfigurasikan parameter instans Kafka

Last Updated:Aug 22, 2026

Topik ini menjelaskan cara mengonfigurasikan parameter tertentu dan menemukan nilainya ketika targetnya adalah instans Message Queue for Apache Kafka yang diakses melalui Express Connect, VPN Gateway, or Smart Access Gateway.

Catatan penggunaan

  • Saat Anda menghubungkan instans Message Queue for Apache Kafka ke Data Transmission Service (DTS) menggunakan metode ini, DTS menulis data ke node yang Anda tentukan.

  • Jika database sumber Anda adalah MySQL, kami menyarankan agar Anda menggunakan Alibaba Cloud Instance Access Method untuk menghubungkan Message Queue for Apache Kafka ke DTS.

  • Ketika targetnya adalah instans Message Queue for Apache Kafka, Schema Migration dan Schema Synchronization tidak didukung.

Parameter

Parameter①

Deskripsi

Cara menemukan②

Access Method

Pilih Express Connect, VPN Gateway, or Smart Access Gateway.

Penting

Untuk beberapa Tugas DTS, Anda tidak dapat langsung memilih Message Queue for Apache Kafka. Dalam kasus ini, konfigurasikan sinkronisasi data dengan memperlakukan instans tersebut sebagai kluster Kafka yang dikelola sendiri.

N/A

Connected VPC

Pilih ID VPC dari instans Message Queue for Apache Kafka.

Pada tab instance information, di bagian Configurations, lihat VPC ID.

Domain Name or IP

Masukkan alamat IP apa pun dari titik akhir default instans Message Queue for Apache Kafka.

Pada tab instance information, di bagian endpoint information, temukan Domain Name Endpoint dengan Type berupa default endpoint.

Catatan
  • Masukkan salah satu alamat IP yang tersedia beserta port-nya.

  • Anda juga dapat mengarahkan kursor ke informasi titik akhir untuk melihat IP Address Endpoint pada tooltip.

Port Number

Masukkan port layanan instans Message Queue for Apache Kafka. Nilai default-nya adalah 9092.

Database Account

Parameter Database Account dan Database Password hanya diperlukan jika Access Control List (ACL) diaktifkan untuk instans Message Queue for Apache Kafka.

Catatan

Untuk informasi lebih lanjut tentang cara mengaktifkan ACL, lihat SASL user authorization.

Pada tab Manage SASL Users, lihat Username.

Database Password

Pada tab Manage SASL Users, temukan akun target lalu klik Copy Password.

Kafka Version

  • Jika Version instans Message Queue for Apache Kafka Anda adalah 0.10.2, pilih 0.10.

  • Jika Version instans Message Queue for Apache Kafka Anda adalah 2.6.2 atau 2.2.0, pilih Later Than 1.0.

Pada tab instance information, di bagian basic information, lihat Major Version.

Encryption

  • Jika ACL diaktifkan untuk instans Message Queue for Apache Kafka dan user type-nya adalah SCRAM, pilih SCRAM-SHA-256.

  • Dalam kasus lain, pilih Non-encrypted.

Pada tab Manage SASL Users, lihat user type instans Message Queue for Apache Kafka.

Catatan

Tab Manage SASL Users hanya ditampilkan untuk instans yang telah mengaktifkan ACL.

  • ① Kolom Parameter dalam tabel berisi parameter khusus yang diperlukan untuk tugas yang tujuannya adalah Message Queue for Apache Kafka.

  • ② Untuk menemukan nilai parameter ini, buka halaman Instances di Konsol Message Queue for Apache Kafka. Pilih wilayah instans target, lalu klik nama instans untuk membuka halaman Instance Details.