Contiguous Offset Commit

Cómo construir una canalización de Kafka que preserve el orden de las sesiones usando Go

Joshua Oluikpe explica un diseño práctico para procesar mensajes de Kafka en orden estricto dentro de cada sesión, manteniendo al mismo tiempo la capacidad de las sesiones independientes para trabajar en paralelo. El diseño se basa en el hashing consistente, un trabajador de Go por sesión, reintentos dentro de la misma ruta y la gestión de puntos de compromiso contiguos para evitar la pérdida de mensajes tras un fallo.