Каким образом обеспечить последовательность получения сообщений Consumer в соответствии с их отправкой в Kafka?

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

• Использовать один и тот же ключ сообщения при отправке, чтобы все сообщения с этим ключом попадали в одну партицию.
• Конфигурировать Consumer так, чтобы он читал сообщения из партиции последовательно.
• Использовать один Consumer на партицию, так как несколько Consumer в одной группе могут читать разные партиции параллельно, что нарушит глобальный порядок.

Пример настройки Producer с ключом:

ProducerRecord<String, String> record = new ProducerRecord<>("topic", "key", "message");
producer.send(record);

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