Следите за последними материалами, объяснениями и связанными технологическими историями.
Joshua Oluikpe описывает практическую архитектуру обработки сообщений Kafka в строгом порядке внутри каждой сессии с возможностью параллельной работы независимых сессий. Архитектура использует согласованное хеширование, отдельную горутину Go для каждой сессии, повторные попытки в том же пути обработки и управление соседними точками фиксации, чтобы избежать потери сообщений после сбоя.