Построение конвейера Kafka с порядком сессий на Go (InfoQ)
В статье InfoQ описана реализация на Go для сохранения порядка сообщений внутри сессий поверх Kafka с использованием согласованного хеширования, двухуровневой иерархии воркеров и одного goroutine на активную сессию. Автор рассказывает о локальных повторных попытках, коммитах по непрерывному ватермарку и операционной доработке (слив при ребалансировке, обратное давление, идемпотентность, очереди мёртвых сообщений) и сообщает об обработке >40M продакшн-сообщений без замеченных нарушений порядка и >100k сообщений/с в тестах.