Kafka кандай бөлүгү бирдей билдирүүлөрдүн кайра окулушун алдын алат?

Kafkaда, бирдей билдирүүлөрдү кайра окууну алдын алуу механизми offsetтер (offsets) жана алардын кармалышы аркылуу камсыз кылынат.

Ар бир бөлүмдөгү билдирүү уникалдуу offsetке — тартип номерине ээ. Тууракчы, ал окуган offsetти көзөмөлдөйт жана аны ырастайт (commit). Кайра ишке киргизүүдө, ал акыркы ырасталган offsetтен окуй баштайт, ошондуктан, ал мурда иштелип чыккан билдирүүлөрдү кайра окууну алдын алат.

Ошентип, кайра окууну алдын алуу үчүн жооптуу компонент — бул өзү consumer, ал commit offset-терди башкарат.