A jeśli wszystkie usługi wysyłają takie wiadomości do Kafka, a obciążenie jest dość wysokie — setki tysięcy wiadomości na sekundę, jak zorganizowałbyś audyt w takim przypadku?