Intercepts all writes to specified directories and send them to kafka brokers