createStream
FlumeUtils