Нам нужно перехватывать все запросы в Kafka и отправлять в систему аудита или телеметрии. Как бы ты это сделал?