Как достичь гарантию порядка в Kafka

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

1. Используйте одинаковый ключ (key) для связанных сообщений - они попадут в одну партицию:

ProducerRecord<String, String> record = 
    new ProducerRecord<>("topic", "sameKey", "message");

2. Настройте max.in.flight.requests.per.connection=1 в продюсере, чтобы избежать переупорядочивания при ретраях.

3. Для консьюмера:

• Используйте один тред на партицию
• Обрабатывайте сообщения последовательно
• Отключайте параллельную обработку (enable.auto.commit=false)

Важно: при увеличении количества партиций порядок между ними не гарантируется. Для глобального порядка потребуется single-partition топик, что снижает пропускную способность.