Integrasikan KPL dengan kode produser - Amazon Kinesis Data Streams

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

Integrasikan KPL dengan kode produser

Kinesis Producer Library (KPL) berjalan dalam proses terpisah, dan berkomunikasi dengan proses pengguna induk Anda menggunakan. IPC Arsitektur ini kadang-kadang disebut microservice, dan dipilih karena dua alasan utama:

1) Proses pengguna Anda tidak akan macet bahkan jika crash KPL

Proses Anda dapat memiliki tugas yang tidak terkait dengan Kinesis Data Streams, dan mungkin dapat melanjutkan operasi bahkan jika crash. KPL Dimungkinkan juga bagi proses pengguna induk Anda untuk memulai ulang KPL dan memulihkan ke keadaan berfungsi penuh (fungsi ini ada di pembungkus resmi).

Contohnya adalah server web yang mengirimkan metrik ke Kinesis Data Streams; server dapat terus melayani halaman bahkan jika bagian Kinesis Data Streams telah berhenti bekerja. Crash seluruh server karena bug di karenanya KPL akan menyebabkan pemadaman yang tidak perlu.

2) Klien arbitrer dapat didukung

Selalu ada pelanggan yang menggunakan bahasa selain yang didukung secara resmi. Pelanggan ini juga harus dapat menggunakannya dengan KPL mudah.

Matriks penggunaan yang disarankan

Matriks penggunaan berikut menyebutkan pengaturan yang disarankan untuk pengguna yang berbeda dan memberi tahu Anda tentang apakah dan bagaimana Anda harus menggunakan. KPL Perlu diingat bahwa jika agregasi diaktifkan, de-agregasi juga harus digunakan untuk mengekstrak catatan Anda di sisi konsumen.

Bahasa sampingan produser Bahasa sisi konsumen KCLVersi Logika titik pemeriksaan Dapatkah Anda menggunakanKPL? Peringatan
Apa pun kecuali Java * * * Tidak N/A
Java Java Menggunakan Java SDK secara langsung N/A Ya Jika agregasi digunakan, Anda harus menggunakan pustaka de-agregasi yang disediakan setelah panggilan. GetRecords
Java Apa pun kecuali Java Menggunakan SDK secara langsung N/A Ya Harus menonaktifkan agregasi.
Java Java 1.3.x N/A Ya Harus menonaktifkan agregasi.
Java Java 1.4.x Panggilan pos pemeriksaan tanpa argumen Ya Tidak ada
Java Java 1.4.x Memanggil pos pemeriksaan dengan nomor urut eksplisit Ya Nonaktifkan agregasi, atau ubah kode untuk menggunakan nomor urutan yang diperluas untuk pos pemeriksaan.
Java Apa pun kecuali Java 1.3.x+daemon multibahasa+pembungkus khusus bahasa N/A Ya Harus menonaktifkan agregasi.