Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Mengkonfigurasi sumber acara Amazon MSK untuk Lambda
Untuk menggunakan cluster Amazon MSK sebagai sumber peristiwa untuk fungsi Lambda Anda, Anda membuat pemetaan sumber peristiwa yang menghubungkan kedua sumber daya. Halaman ini menjelaskan cara membuat pemetaan sumber peristiwa untuk Amazon MSK.
Halaman ini mengasumsikan bahwa Anda telah mengkonfigurasi cluster MSK dengan benar dan Amazon Virtual Private Cloud (VPC) yang berada di dalamnya. Jika Anda perlu mengatur cluster atau VPC Anda, lihatMengkonfigurasi cluster Amazon MSK dan jaringan Amazon VPC Anda untuk Lambda. Untuk mengonfigurasi perilaku coba ulang untuk penanganan kesalahan, lihatMengkonfigurasi kontrol penanganan kesalahan untuk sumber peristiwa Kafka.
Topik
Menggunakan cluster Amazon MSK sebagai sumber peristiwa
Saat Anda menambahkan cluster Apache Kafka atau Amazon MSK sebagai pemicu untuk fungsi Lambda Anda, cluster digunakan sebagai sumber peristiwa.
Lambda membaca data peristiwa dari topik Kafka yang Anda tentukan seperti Topics dalam CreateEventSourceMapping permintaan, berdasarkan posisi awal yang Anda tentukan. Setelah pemrosesan berhasil, topik Kafka Anda dijalankan untuk klaster Kafka Anda.
Lambda membaca pesan secara berurutan untuk setiap partisi topik Kafka. Satu muatan Lambda dapat berisi pesan dari beberapa partisi. Ketika lebih banyak catatan tersedia, Lambda terus memproses catatan dalam batch, berdasarkan BatchSize nilai yang Anda tentukan dalam CreateEventSourceMapping permintaan, hingga fungsi Anda mengejar topik.
Setelah Lambda memproses setiap batch, Lambda melakukan offset pesan dalam batch tersebut. Jika fungsi Anda mengembalikan kesalahan untuk salah satu pesan dalam batch, Lambda mencoba ulang seluruh batch pesan sampai berhasil diproses atau pesan berakhir. Anda dapat mengirim catatan yang gagal dalam semua upaya percobaan ulang ke tujuan saat gagal untuk diproses nanti.
catatan
Sementara fungsi Lambda biasanya memiliki batas waktu tunggu maksimum 15 menit, pemetaan sumber peristiwa untuk Amazon MSK, Apache Kafka yang dikelola sendiri, Amazon DocumentDB, dan Amazon MQ untuk ActiveMQ dan RabbitMQ hanya mendukung fungsi dengan batas waktu tunggu maksimum 14 menit.
