E se todos os serviços enviam essas mensagens para o Kafka, e a carga é bastante alta — centenas de milhares de mensagens por segundo, como você organizaria uma auditoria nesse caso?