Pilihan Pengakuan Mesej Kafka

Pilihan Pengakuan Mesej Kafka

Kafka menawarkan beberapa pilihan pengakuan mesej, memberi kesan kepada prestasi dan kebolehpercayaan. Pilihan ini mengawal bagaimana pengguna isyarat kepada broker bahawa ia telah berjaya memproses mesej. Pilihan utama adalah:

• Pengakuan automatik: Pengguna secara automatik mengakui mesej selepas selang waktu tertentu atau selepas memproses sejumlah mesej tertentu. Ini adalah pendekatan yang paling mudah, yang menawarkan kebolehpercayaan yang tinggi tetapi mengorbankan kebolehpercayaan. Sekiranya pengguna terhempas sebelum mengakui, mesej dianggap diproses, berpotensi membawa kepada kehilangan data. Ini menawarkan kebolehpercayaan tertinggi kerana mesej hanya dianggap dimakan selepas pengakuan eksplisit. Walau bagaimanapun, ia dilengkapi dengan overhead prestasi kerana koordinasi tambahan yang diperlukan. Pengguna boleh mengiktiraf offset tertentu, walaupun dalam kumpulan mesej yang diterima. Ini memberikan fleksibiliti untuk mengendalikan kegagalan pemprosesan mesej individu sambil mengekalkan tahap prestasi yang munasabah. Offset adalah pengecam unik untuk setiap mesej dalam partition. Apabila pengguna melanggan topik, ia menerima satu set mesej bermula dari offset tertentu. Strategi pengakuan menentukan bagaimana dan bila pengguna mengemas kini mengimbangi, menunjukkan kepada broker bahawa ia telah memproses mesej tersebut.
• Pengakuan automatik: Broker secara automatik mengemas kini offset berdasarkan masa atau kiraan mesej yang dikonfigurasikan. Sekiranya pengguna gagal sebelum pengakuan automatik, mesej hilang. Strategi ini terdedah kepada kehilangan data tetapi menawarkan throughput tertinggi. Ini adalah operasi menyekat; Pengguna menunggu pengesahan broker sebelum memproses mesej seterusnya. Ini menjamin penghantaran mesej tetapi memberi kesan kepada prestasi disebabkan oleh sifat segerak. Ini meningkatkan prestasi dengan ketara tetapi memperkenalkan kemungkinan kehilangan data jika pengguna terhempas sebelum komitmen tak segerak selesai. Panggilan balik boleh digunakan untuk menangani kegagalan komitmen yang berpotensi. Sekiranya pemprosesan mesej gagal, pengguna boleh memilih untuk tidak mengakui bahawa mengimbangi tertentu, yang membolehkan pemrosesan semula kemudian. Ini memberikan kebolehpercayaan tanpa penalti prestasi serentak mengakui setiap mesej. tetapi risiko kehilangan data tertinggi. Ini selalunya pilihan paling lambat. Sifat asynchronous membolehkan prestasi yang lebih baik daripada pendekatan segerak tetapi masih mempunyai risiko kehilangan data yang lebih tinggi berbanding dengan pengakuan segerak. Pilihan ini menawarkan keseimbangan yang baik antara throughput dan kebolehpercayaan. Prestasi sebenar bergantung kepada kekerapan kegagalan mesej individu.
  • Untuk aplikasi di mana kehilangan data boleh diterima dan throughput yang tinggi adalah kritikal (mis., Pembalakan, metrik): Pengakuan automatik adalah pilihan yang sesuai. dengan batasan prestasi. Pertimbangkan menggunakan mekanisme semula untuk mengendalikan pemprosesan mesej yang gagal. Berhati-hati mempertimbangkan perdagangan antara throughput dan kebolehpercayaan untuk memilih pilihan yang terbaik memenuhi keperluan anda.

Atas ialah kandungan terperinci Pilihan Pengakuan Mesej Kafka. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!