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