Buat konektor

Membuat konektor menggunakan AWS Management Console

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

2. Di panel kiri, di bawah MSKConnect, pilih Connectors.

3. Pilih Buat konektor.

4. Anda dapat memilih antara menggunakan plugin khusus yang ada untuk membuat konektor, atau membuat plugin khusus baru terlebih dahulu. Untuk informasi tentang plugin khusus dan cara membuatnya, lihatBuat plugin kustom. Dalam prosedur ini, mari kita asumsikan Anda memiliki plugin khusus yang ingin Anda gunakan. Dalam daftar plugin khusus, temukan salah satu yang ingin Anda gunakan, dan pilih kotak di sebelah kirinya, lalu pilih Berikutnya.

5. Masukkan nama dan, secara opsional, deskripsi.

6. Pilih cluster yang ingin Anda sambungkan.

7. Tentukan konfigurasi konektor. Parameter konfigurasi yang perlu Anda tentukan bergantung pada jenis konektor yang ingin Anda buat. Namun, beberapa parameter umum untuk semua konektor, misalnya, connector.class dan tasks.max parameter. Berikut ini adalah contoh konfigurasi untuk Confluent Amazon S3 Sink Connector.

   connector.class=io.confluent.connect.s3.S3SinkConnector
   tasks.max=2
   topics=my-example-topic
   s3.region=us-east-1
   s3.bucket.name=my-destination-bucket
   flush.size=1
   storage.class=io.confluent.connect.s3.storage.S3Storage
   format.class=io.confluent.connect.s3.format.json.JsonFormat
   partitioner.class=io.confluent.connect.storage.partitioner.DefaultPartitioner
   key.converter=org.apache.kafka.connect.storage.StringConverter
   value.converter=org.apache.kafka.connect.storage.StringConverter
   schema.compatibility=NONE

8. Selanjutnya, Anda mengonfigurasi kapasitas konektor Anda. Anda dapat memilih di antara dua mode kapasitas: provisioned dan auto scaled. Untuk informasi tentang dua opsi ini, lihatMemahami kapasitas konektor.

9. Pilih konfigurasi pekerja default atau konfigurasi pekerja khusus. Untuk informasi tentang membuat konfigurasi pekerja kustom, lihatMemahami pekerja MSK Connect.

10. Selanjutnya, Anda menentukan peran eksekusi layanan. Ini harus menjadi IAM peran yang dapat diasumsikan oleh MSK Connect, dan yang memberikan konektor semua izin yang diperlukan untuk mengakses sumber daya yang diperlukan AWS . Izin tersebut tergantung pada logika konektor. Untuk informasi tentang cara membuat peran ini, lihatMemahami peran eksekusi layanan.

11. Pilih Berikutnya, tinjau informasi keamanan, lalu pilih Berikutnya lagi.

12. Tentukan opsi logging yang Anda inginkan, lalu pilih Berikutnya. Untuk informasi tentang pencatatan, lihatLogging untuk MSK Connect.

13. Pilih Buat konektor.