Buat plugin kustom - Amazon Managed Streaming untuk Apache Kafka

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Buat plugin kustom

Plugin adalah AWS sumber daya yang berisi kode yang mendefinisikan logika konektor Anda. Anda mengunggah file JAR (atau file ZIP yang berisi satu atau beberapa file JAR) ke bucket S3, dan tentukan lokasi bucket saat Anda membuat plugin. Ketika plugin dibuat, MSK Connect menyalin konten objek S3 pada saat itu. Itu tidak mempertahankan tautan ke objek S3, sehingga modifikasi selanjutnya pada objek tidak akan mempengaruhi plugin atau konektornya. Saat Anda membuat konektor, Anda menentukan plugin yang ingin digunakan MSK Connect untuk itu. Hubungan plugin dengan konektor adalah one-to-many: Anda dapat membuat satu atau lebih konektor dari plugin yang sama.

catatan

Plugin khusus tidak dapat diperbarui di tempat. Untuk menggunakan versi baru kode plugin Anda, hapus semua konektor yang mereferensikan plugin, hapus plugin, lalu buat ulang.

Kemasan ketergantungan untuk plugin khusus

Kami menyarankan Anda menyertakan semua file JAR yang diperlukan dan dependensi untuk plugin Anda. Package konektor Anda sebagai salah satu dari berikut ini:

  • File ZIP yang berisi semua file JAR yang diperlukan dan dependensi untuk plugin.

  • Uber JAR tunggal yang berisi semua file kelas untuk plugin dan dependensinya.

Tidak menggabungkan dependensi plugin Anda dapat memengaruhi ketersediaan atau kompatibilitas di lingkungan runtime dan menyebabkan kesalahan yang tidak terduga.

Untuk informasi tentang cara mengembangkan kode untuk konektor, lihat Panduan Pengembangan Konektor di dokumentasi Apache Kafka.

Membuat plugin khusus menggunakan Konsol Manajemen AWS

  1. Buka konsol MSK Amazon dihttps://console.aws.amazon.com/msk/.

  2. Di panel kiri, di bawah MSK Connect, pilih Plugin kustom.

  3. Pilih Buat plugin kustom.

  4. Pilih Jelajahi S3.

  5. Dalam daftar bucket S3, pilih bucket yang memiliki file JAR atau ZIP untuk plugin.

  6. Dalam daftar objek, pilih kotak di sebelah kiri file JAR atau ZIP untuk plugin, lalu pilih Pilih.

  7. Pilih Buat plugin kustom.

Untuk menggunakan MSK Connect API untuk membuat plugin khusus, lihat CreateCustomPlugin.