Kafka'da, ayni xabarlarni takroriy o'qishni oldini olish offsetlar mexanizmi va ularni iste'molchi (consumer) tomonida boshqarish orqali ta'minlanadi.

Har bir xabar bo'linmada noyob offsetga ega — ketma-ket raqam. Iste'molchi o'qigan offsetini kuzatadi va tasdiqlaydi (commit). Qayta ishga tushirilganda, iste'molchi oxirgi tasdiqlangan offsetdan o'qishni boshlaydi, shuning uchun allaqachon ishlov berilgan xabarlarni takroriy o'qish oldi olinadi.

Shunday qilib, takroriy o'qishni oldini olish uchun javobgar bo'lim — bu o'zini consumer bo'lib, u commit offsetlarini boshqaradi.

Oldingi Keyingi