Contiguous Offset Commit

Comment construire un pipeline Kafka qui préserve l’ordre des sessions avec Go

Joshua Oluikpe décrit une conception pratique pour traiter les messages Kafka dans un ordre strict au sein de chaque session, tout en permettant aux sessions indépendantes de fonctionner en parallèle. La conception repose sur le hachage cohérent, un worker Go par session, la nouvelle tentative au sein du même flux et la gestion de points de validation contigus afin d’éviter la perte de messages après un incident.