Add support for flume

Add support for streaming inputs from flume.