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

В Kafka порядок сообщений гарантируется только в пределах одного партиции. Сообщения в партиции строго упорядочены по offset'у. Для обеспечения порядка:

1. Партиционирование: Сообщения с одинаковым ключом (key) попадают в одну партицию. Пример:

// Отправка сообщения с ключом для гарантии порядка
producer.send(new ProducerRecord<>("topic", "key1", "message1"));

2. Настройки продюсера:

• max.in.flight.requests.per.connection=1 (отключает параллельную отправку)
• acks=all (гарантирует запись во все реплики)

3. Консьюмеры:

• Чтение из одной партиции одним консьюмером в группе
• Обработка сообщений последовательно (без параллелизма)

Между разными партициями порядок не гарантируется. Для глобального порядка нужна одна партиция, но это ограничивает пропускную способность.