This module provides a re-usable and environment agnostic control of flume-repose & cf-flume-sink: https://repose.atlassian.net/wiki/display/REPOSE/CF+Flume+sink - View it on GitHub