Как решалась проблема порядка событий в Kafka (ordering) при audit trail для сущностей?

В Kafka порядок событий гарантируется внутри одного партициона, но не между разными партициями. Для audit trail по сущностям обычно используют ключи сообщений, чтобы все события одной сущности попадали в один партицион, сохраняя порядок. Если сущностей много и нужна масштабируемость, можно использовать ключи, основанные на идентификаторах сущностей, чтобы распределить нагрузку, но при этом порядок для каждой сущности сохраняется. Также иногда применяют дополнительную логику на стороне потребителя для упорядочивания событий, если они приходят из разных партиций.