spark streaming integration flume