Flume source and sink for correctness testing.