Buat langganan data dalam mode Push - Lindorm - Alibaba Cloud Documentation Center

Lindorm Streams memungkinkan Anda berlangganan perubahan inkremental—penyisipan, pembaruan, dan penghapusan—pada tabel Lindorm serta mendorong perubahan tersebut secara real time ke topik Message Queue for Apache Kafka. Setelah aliran Lindorm diaktifkan pada suatu tabel, fitur pelacakan perubahan akan mencatat setiap operasi data dan mengirimkan catatan event ke topik Kafka yang Anda tentukan.

Prasyarat

Sebelum memulai, pastikan Anda telah:

Menambahkan alamat IP client Lindorm dan client Message Queue for Apache Kafka ke daftar putih instans Lindorm Anda. Lihat Konfigurasi daftar putih.
Menghubungkan instans Lindorm sumber dan instans Message Queue for Apache Kafka tujuan ke Lindorm Tunnel Service (LTS). Lihat Koneksi jaringan.
Membuat sumber data LindormTable. Lihat Tambahkan sumber data LindormTable.
Membuat sumber data Kafka. Lihat Tambahkan sumber data Kafka.
Mengaktifkan fitur pelacakan perubahan. Lihat Aktifkan pelacakan perubahan.

Buat aliran Lindorm

Masuk ke antarmuka pengguna web (UI) LTS instans Lindorm Anda. Di panel navigasi sebelah kiri, pilih Change Data Capture > Push.

Klik create, lalu konfigurasikan parameter yang dijelaskan dalam tabel berikut.

Parameter	Deskripsi	Tipe	Bawaan
Lindorm Cluster	Pilih sumber data LindormTable yang telah Anda buat.	—	—
The table name.	Masukkan nama tabel yang data inkrementalnya ingin Anda langgani, dalam format `Namespace.NamaTabel`. Contohnya: `ns1.table1` berlangganan ke `table1` di namespace `ns1`; `ns2.*` berlangganan ke semua tabel di namespace `ns2`.	String	—
Stream Config – `key_only`	Atur ke `true` untuk hanya mengekspor nilai kunci primary.	Boolean	`false`
Stream Config – `order_output`	Atur ke `true` untuk mencatat operasi penyisipan, penghapusan, dan pembaruan secara berurutan berdasarkan nilai kunci primary.	Boolean	`false`
MessageStorage Type	Pilih `KAFKA`.	—	—
Storage Datasource	Pilih sumber data Kafka yang telah Anda buat.	—	—
MessageStorage Config – `kafka_topic`	Masukkan nama topik Message Queue for Apache Kafka tempat data pelacakan perubahan dikirimkan.	String	—
MessageVersion	Format data untuk catatan aliran.	String	`DebeziumV1`
Message Config – `old_image`	Atur ke `true` untuk menyertakan data baris sebelum operasi dalam setiap catatan aliran. Jika diaktifkan, catatan UPDATE dan DELETE akan membawa nilai bidang asli. Jika diatur ke `false`, data baris sebelum operasi tidak disertakan dalam catatan aliran.	Boolean	`true`
Message Config – `new_image`	Atur ke `true` untuk menyertakan data baris setelah operasi dalam setiap catatan aliran. Jika diaktifkan, catatan INSERT dan UPDATE akan membawa nilai bidang hasil operasi.	Boolean	`true`

配置页面

Klik Commit.