Gunakan Perpustakaan Klien Kinesis - Amazon Kinesis Data Streams

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

Gunakan Perpustakaan Klien Kinesis

Apa itu Perpustakaan Klien Kinesis?

Kinesis Client Library (KCL) adalah pustaka perangkat lunak Java mandiri yang dirancang untuk menyederhanakan proses konsumsi dan pemrosesan data dari Amazon Kinesis Data Streams. KCLmenangani banyak tugas kompleks yang terkait dengan komputasi terdistribusi, memungkinkan pengembang untuk fokus pada penerapan logika bisnis mereka untuk memproses data. Ini mengelola aktivitas seperti penyeimbangan beban di beberapa pekerja, menanggapi kegagalan pekerja, memeriksa catatan yang diproses, dan menanggapi perubahan jumlah pecahan dalam aliran.

KCLsering diperbarui untuk menggabungkan versi yang lebih baru dari pustaka yang mendasarinya, peningkatan keamanan, dan perbaikan bug. Kami menyarankan Anda untuk menggunakan versi terbaruKCL. Untuk menemukan KCL versi terbaru, lihat KCLGithub.

penting

KCLadalah perpustakaan Java. Support untuk bahasa selain Java disediakan menggunakan daemon berbasis Java yang disebut. MultiLangDaemon MultiLangDaemon berinteraksi dengan KCL aplikasi secara berulang-ulang STDIN danSTDOUT. Untuk informasi lebih lanjut tentang MultiLangDaemon on GitHub, lihatMengembangkan konsumen dengan KCL bahasa non-Jawa.

KCLfitur dan manfaat utama

Berikut ini adalah fitur utama dan manfaat terkait dariKCL:

  • Skalabilitas: KCL memungkinkan aplikasi untuk menskalakan secara dinamis dengan mendistribusikan beban pemrosesan ke beberapa pekerja. Anda dapat menskalakan aplikasi masuk atau keluar, secara manual atau dengan auto-scaling, tanpa khawatir tentang redistribusi beban.

  • Load balancing: KCL secara otomatis menyeimbangkan beban pemrosesan di seluruh pekerja yang tersedia, menghasilkan distribusi pekerjaan yang merata di seluruh pekerja.

  • Checkpointing: KCL mengelola checkpointing catatan yang diproses, memungkinkan aplikasi untuk melanjutkan pemrosesan dari posisi terakhir yang berhasil diproses.

  • Toleransi kesalahan: KCL menyediakan mekanisme toleransi kesalahan bawaan, memastikan bahwa pemrosesan data berlanjut bahkan jika pekerja individu gagal. KCLjuga menyediakan at-least-once pengiriman.

  • Menangani perubahan tingkat aliran: KCL beradaptasi dengan pecahan pecahan dan penggabungan yang mungkin terjadi karena perubahan volume data. Ini mempertahankan pemesanan dengan memastikan bahwa pecahan anak diproses hanya setelah pecahan induknya selesai dan diperiksa.

  • Pemantauan: KCL terintegrasi dengan Amazon CloudWatch untuk pemantauan tingkat konsumen.

  • Dukungan multi-bahasa: KCL secara native mendukung Java dan memungkinkan beberapa bahasa pemrograman non-Java melalui. MultiLangDaemon