А если все сервисы пишут такие сообщения в Kafka, и нагрузка достаточно высокая — сотни тысяч сообщений в секунду, как бы вы организовали аудит в этом случае?