A custom flume sink implementation that triggers a long running kettle transformation for event processing