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