Contiguous Offset Commit

Como criar um pipeline Kafka que preserve a ordem das sessões usando Go

Joshua Oluikpe explica um projeto prático para processar mensagens do Kafka em ordem estrita dentro de cada sessão, mantendo sessões independentes capazes de operar em paralelo. O projeto utiliza hashing consistente, um worker Go por sessão, novas tentativas dentro do mesmo fluxo e gerenciamento de pontos de commit contíguos para evitar a perda de mensagens após uma falha.