ApsaraMQ for Kafka menyediakan konektor sink yang sepenuhnya dikelola dan bebas operasi untuk menyinkronkan data antara ApsaraMQ for Kafka dan layanan Alibaba Cloud lainnya. Topik ini menjelaskan prasyarat penggunaan konektor sink serta jenis tugas sinkronisasi data yang didukung.
Prasyarat
Konektor sink diimplementasikan berdasarkan EventBridge dan Function Compute. Sebelum menggunakan konektor sink, pastikan layanan berikut telah diaktifkan:
- Aktifkan EventBridge dan berikan izin kepada pengguna RAM
- Function Compute diaktifkan. Untuk informasi lebih lanjut, lihat Aktifkan Function Compute.
Tagihan
- EventBridge sedang dalam versi pratinjau publik. Tidak ada biaya selama periode pratinjau publik.
- Untuk informasi tentang penagihan Function Compute, lihat Ikhtisar Penagihan.
Jenis Konektor
Sink dalam konektor sink menunjukkan aliran keluar data. Saat menggunakan konektor sink yang disediakan oleh Message Queue for Apache Kafka, ApsaraMQ for Kafka berfungsi sebagai sumber data, dan layanan lainnya bertindak sebagai tujuan data. Tabel berikut menggambarkan jenis-jenis konektor sink.
| Konektor | Deskripsi | Referensi |
| Konektor sink Function Compute | Menyinkronkan data dari ApsaraMQ for Kafka ke Function Compute. | Buat Konektor sink Function Compute |
| Konektor sink MaxCompute | Menyinkronkan data dari ApsaraMQ for Kafka ke MaxCompute. | Buat Konektor sink MaxCompute |
| Konektor sink OSS | Menyinkronkan data dari ApsaraMQ for Kafka ke Object Storage Service (OSS). | Buat Konektor sink OSS |
| Konektor sink Elasticsearch | Menyinkronkan data dari ApsaraMQ for Kafka ke Elasticsearch. | Buat Konektor sink Elasticsearch |
| Konektor sink Tablestore | Menyinkronkan data dari ApsaraMQ for Kafka ke Tablestore. | Buat Konektor sink Tablestore |
| Konektor sink Layanan Log | Menyinkronkan data dari ApsaraMQ for Kafka ke Layanan Log. | Buat Konektor sink Simple Log Service |
| Konektor sink AnalyticDB | Menyinkronkan data dari ApsaraMQ for Kafka ke AnalyticDB for MySQL atau AnalyticDB for PostgreSQL. | Buat Konektor sink AnalyticDB |