ApsaraMQ for Kafka:Buat konektor sink ApsaraMQ for Kafka

Buat konektor sink

1. Masuk ke konsol ApsaraMQ for Kafka. Di bagian Resource Distribution pada halaman Overview, pilih wilayah tempat instance ApsaraMQ for Kafka yang ingin Anda kelola berada.

2. Di panel navigasi sisi kiri, pilih Connector Ecosystem Integration > Tasks.

3. Di halaman Tasks, klik Create Task.

4. Di halaman Create Task, konfigurasikan parameter Task Name dan Description serta ikuti petunjuk di layar untuk mengonfigurasi parameter lainnya. Lalu, klik Save. Bagian berikut menjelaskan parameter:

   • Pembuatan Tugas

     1. Di langkah Source, atur parameter Data Provider menjadi ApsaraMQ for Kafka dan ikuti petunjuk di layar untuk mengonfigurasi parameter lainnya. Lalu, klik Next Step. Tabel berikut menjelaskan parameter.

        Parameter	Deskripsi	Contoh
        Region	Wilayah tempat instance sumber ApsaraMQ for Kafka berada.	Tiongkok (Beijing)
        ApsaraMQ for Kafka Instance	Instance ApsaraMQ for Kafka tempat pesan yang ingin Anda rutekan diproduksi.	MQ_INST_115964845466****_ByBeUp3p
        Topic	Topik pada instance ApsaraMQ for Kafka tempat pesan yang ingin Anda rutekan diproduksi.	topik
        Group ID	Nama grup konsumen pada instance ApsaraMQ for Kafka sumber. Anda harus menggunakan grup konsumen terpisah untuk membuat sumber rute pesan. Jangan gunakan grup konsumen yang sedang digunakan. Jika tidak, pesan yang ada mungkin gagal dikirim dan diterima.	GID_http_1
        Consumer Offset	Offset tempat pesan dikonsumsi.	Offset Terbaru
        Network Configuration	Jenis jaringan tempat Anda ingin merutekan pesan.	Jaringan Dasar
        VPC	ID virtual private cloud (VPC) tempat instance ApsaraMQ for Kafka diterapkan. Parameter ini hanya diperlukan jika Anda menetapkan parameter Network Configuration ke Internet Mandiri.	vpc-bp17fapfdj0dwzjkd****
        vSwitch	ID vSwitch yang terhubung dengan instance ApsaraMQ for Kafka. Parameter ini hanya diperlukan jika Anda menetapkan parameter Network Configuration ke Internet Mandiri.	vsw-bp1gbjhj53hdjdkg****
        Security Group	Grup keamanan tempat instance ApsaraMQ for Kafka termasuk. Parameter ini hanya diperlukan jika Anda menetapkan parameter Network Configuration ke Internet Mandiri.	alikafka_pre-cn-7mz2****
        Messages	Jumlah maksimum pesan yang dapat dikirim dalam setiap pemanggilan fungsi. Permintaan hanya dikirim ketika jumlah pesan dalam backlog mencapai nilai yang ditentukan. Nilai valid: 1 hingga 10000.	100
        Interval (Unit: Seconds)	Interval waktu saat fungsi dipanggil. Sistem mengirimkan pesan teragregasi ke Function Compute pada interval waktu yang ditentukan. Nilai valid: 0 hingga 15. Satuan: detik. Nilai 0 menentukan bahwa pesan dikirim segera setelah agregasi.	3

     2. Di langkah Filtering, definisikan pola data di editor kode Pattern Content untuk memfilter data. Untuk informasi lebih lanjut, lihat Pola Acara.

     3. Di langkah Transformation, tentukan metode pembersihan data untuk mengimplementasikan kemampuan pemisahan, pemetaan, pengayaan, dan perutean data. Untuk informasi lebih lanjut, lihat Gunakan Function Compute untuk Melakukan Pembersihan Pesan.

     4. Di langkah Sink, atur parameter Service Type menjadi ApsaraMQ for Kafka dan ikuti petunjuk di layar untuk mengonfigurasi parameter lainnya. Tabel berikut menjelaskan parameter.

        Parameter	Deskripsi	Contoh
        Instance ID	Instance tujuan ApsaraMQ for Kafka yang Anda buat.	test
        Topic	Topik pada instance tujuan ApsaraMQ for Kafka yang Anda buat.	test
        Acknowledgment Mode	Mode yang digunakan ApsaraMQ for Kafka untuk mengakui data yang diterima. None LeaderOnly All	Tidak Ada
        Message Value	EventBridge mengekstraksi data dari pesan menggunakan JSONPath dan merutekan konten tertentu dari pesan ke target acara. Complete Data Data Extraction Fixed Value Template	Ekstraksi Data $.data.value
        Message Key	EventBridge mengekstraksi data dari pesan menggunakan JSONPath dan merutekan konten tertentu dari pesan ke target acara. Empty Data Extraction Fixed Value Template	Ekstraksi Data $.data.key

   • Properti Tugas

     Konfigurasikan kebijakan ulang dan antrian pesan gagal untuk tugas. Untuk informasi lebih lanjut, lihat Kebijakan Ulang dan Antrian Pesan Gagal.

5. Kembali ke halaman Tasks, temukan konektor sink ApsaraMQ for Kafka yang Anda buat, lalu klik Enable di kolom Actions.

6. Di pesan Note, klik OK.

   Konektor memerlukan waktu 30 hingga 60 detik untuk diaktifkan. Anda dapat melihat kemajuan di kolom Status pada halaman Tasks.

Operasi lainnya

Di halaman Tasks, temukan tugas aliran keluar pesan yang ingin Anda kelola dan lakukan operasi lainnya di kolom Actions. Item berikut menjelaskan operasi yang dapat Anda lakukan:

• Lihat detail tugas: Klik Details di kolom Tindakan. Di halaman yang muncul, lihat informasi dasar, properti, dan metrik pemantauan tugas.

• Ubah konfigurasi tugas: Klik Edit di kolom Tindakan. Di panel Edit Task, ubah konfigurasi tugas.

• Aktifkan atau nonaktifkan tugas: Klik Enable atau Pause di kolom Tindakan. Di pesan Note, klik OK.

• Hapus tugas: Klik Delete di kolom Tindakan. Di pesan Note, klik OK.