Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Polling Apache Kafka dan posisi awal streaming di Lambda
StartingPosition Parameter memberi tahu Lambda kapan harus mulai membaca pesan dari Amazon MSK atau aliran Apache Kafka yang dikelola sendiri. Ada tiga opsi untuk dipilih:
-
Ter baru — Lambda mulai membaca tepat setelah catatan terbaru dalam topik Kafka.
-
Trim horizon — Lambda mulai membaca dari catatan terakhir yang belum dipangkas dalam topik Kafka. Ini juga catatan tertua dalam topik.
-
Pada stempel waktu — Lambda mulai membaca dari posisi yang ditentukan oleh stempel waktu, dalam detik waktu Unix. Gunakan StartingPositionTimestamp parameter untuk menentukan stempel waktu.
Polling aliran selama pembuatan atau pembaruan pemetaan sumber peristiwa pada akhirnya konsisten:
-
Selama pembuatan pemetaan sumber peristiwa, mungkin diperlukan beberapa menit untuk memulai polling peristiwa dari aliran.
-
Selama pembaruan pemetaan sumber peristiwa, mungkin diperlukan waktu hingga 90 detik untuk menghentikan dan memulai ulang peristiwa polling dari aliran.
Perilaku ini berarti bahwa jika Anda menentukan LATEST sebagai posisi awal untuk aliran, pemetaan sumber peristiwa dapat melewatkan peristiwa selama pembuatan atau pembaruan. Untuk memastikan bahwa tidak ada acara yang terlewatkan, tentukan salah TRIM_HORIZON satu atauAT_TIMESTAMP.
