Как в Kafka поддерживается порядок сообщений и гарантируется их недопотеря?

В Kafka порядок сообщений гарантируется внутри одного партициона топика. Сообщения, отправленные в один партицион, сохраняются и потребляются строго в том порядке, в котором были записаны. Для этого Kafka использует смещения (offset) — уникальные последовательные номера сообщений в партиционе.

Гарантия недопотери достигается за счет следующих механизмов:

• Репликация: Каждая партиция имеет несколько реплик на разных брокерах. Если основной брокер выходит из строя, одна из реплик становится лидером.
• Подтверждения записи (acks): Продюсер может настроить уровень подтверждений (например, ждать подтверждения от всех реплик), чтобы убедиться, что сообщение надежно сохранено.
• Коммит оффсетов: Консьюмеры сохраняют смещения прочитанных сообщений, чтобы при сбое продолжить чтение с нужного места.

Таким образом, Kafka обеспечивает строгий порядок сообщений в пределах партиции и минимизирует риск потери данных благодаря репликации и подтверждениям записи.