ApsaraMQ for Kafka:Buat konektor sink Kafka

Buat tugas konektor sink

1. Masuk ke Konsol ApsaraMQ for Kafka. Pada halaman Overview, pilih wilayah di bagian Resource Distribution.

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

3. Pada halaman Tasks, klik Create Task.

4. Pada panel Create Task, atur Task Name dan Description, konfigurasikan tugas seperti dijelaskan di bawah ini, lalu klik Save.

   • Pembuatan tugas

     1. Pada langkah Source, pilih Message Queue for Apache Kafka sebagai Data Provider. Konfigurasikan parameter berikut, lalu klik Next.

        Parameter	Deskripsi	Contoh
        Region	Wilayah instans sumber Message Queue for Apache Kafka.	China (Beijing)
        Kafka instance	Instans sumber Message Queue for Apache Kafka.	alikafka_post-cn-jte3****
        Topic	Topik tempat pesan dikonsumsi.	demo-topic
        Group ID	Kelompok konsumen instans sumber. Quick Create (disarankan): Group ID dengan format GID_EVENTBRIDGE_xxx dibuat secara otomatis. Use Existing: Pilih group ID yang sudah ada. Jangan gunakan group ID ini bersama layanan lain untuk menghindari gangguan pada konsumsi pesan.	Quick Create
        Consumer offset	Offset tempat konsumsi pesan dimulai. Latest offset (latest) Earliest offset (earliest)	Latest offset (latest)
        Network configuration	Jenis jaringan untuk perutean pesan. Basic Network Self-managed Internet	Basic Network
        VPC	Diperlukan hanya jika Network configuration diatur ke Self-managed Internet.	vpc-bp17fapfdj0dwzjkd****
        vSwitch	Diperlukan hanya jika Network configuration diatur ke Self-managed Internet.	vsw-bp1gbjhj53hdjdkg****
        Security group	Diperlukan hanya jika Network configuration diatur ke Self-managed Internet.	alikafka_pre-cn-7mz2****
        Data Format	Format encoding untuk konten pesan. Kami merekomendasikan Json jika Anda tidak memiliki persyaratan encoding khusus. Json: Meng-encode data biner sebagai objek JSON ke dalam muatan menggunakan UTF-8. Text: Meng-encode data biner sebagai string UTF-8 ke dalam muatan. Ini adalah format default. Binary: Meng-encode data biner sebagai string Base64-encoded ke dalam muatan.	Json
        Messages	Parameter Advanced configuration. Jumlah maksimum pesan per batch. Permintaan dikirim ketika jumlah pesan terakumulasi mencapai nilai ini. Nilai valid: 1 hingga 10.000.	100
        Interval (Unit: Seconds)	Parameter Advanced configuration. Interval, dalam detik, saat pesan diagregasi dan dikirim ke sink. Nilai valid: 0 hingga 15. Nilai 0 berarti pesan dikirimkan segera.	3

     2. Pada langkah Filtering, atur Pattern Content untuk memfilter event. Untuk informasi selengkapnya, lihat event pattern.

     3. Pada langkah Transformation, konfigurasikan transformasi data untuk melakukan operasi seperti pemisahan, pemetaan, pengayaan, dan perutean dinamis. Untuk informasi selengkapnya, lihat Gunakan Function Compute untuk membersihkan data pesan.

     4. Pada langkah Sink, atur Service Type ke ApsaraMQ for Kafka dan konfigurasikan parameter berikut.

        Parameter	Deskripsi	Contoh
        Instance ID	Pilih instans tujuan ApsaraMQ for Kafka.	test
        Topic	Pilih topik di instans tujuan.	test
        Acknowledgment Mode	Pilih sinyal acknowledgement yang dikirimkan ApsaraMQ for Kafka ke client setelah menerima data. None LeaderOnly All	None
        Message Value	EventBridge menggunakan ekspresi JSONPath untuk mengekstrak konten tertentu dari sebuah event dan mengirimkannya ke tujuan. Complete Data Data Extraction Fixed Value Template	Extract from Event $.data.value
        Message Key	EventBridge menggunakan ekspresi JSONPath untuk mengekstrak konten tertentu dari sebuah event dan mengirimkannya ke tujuan. Null Data Extraction Fixed Value Template	Extract from Event $.data.key

   • Properti tugas

     Konfigurasikan kebijakan retry dan dead-letter queue untuk tugas ini. Untuk informasi selengkapnya, lihat Retry dan dead-letter queue.

5. Pada halaman Tasks, temukan tugas Anda dan klik Enable di kolom Actions.

6. Pada kotak dialog Note, baca pesannya lalu klik OK.

   Tugas memerlukan waktu 30 hingga 60 detik untuk mulai setelah diaktifkan. Anda dapat melihat progres startup di kolom Status pada halaman Tasks.

Operasi lainnya

Pada halaman Tasks, temukan tugas yang dituju dan lakukan operasi berikut di kolom Actions.

• Lihat detail tugas: Klik Details. Di halaman Task, Anda dapat melihat informasi dasar tugas, properti, dan metrik pemantauan.

• Edit konfigurasi tugas: Klik Edit. Di panel Edit Task, Anda dapat mengubah detail dan properti tugas.

• Aktifkan atau jeda tugas: Klik Enable atau Pause. Di kotak dialog Note, klik OK.

• Hapus tugas: Klik Delete. Di kotak dialog Note, klik OK.