optimizing TSDBSource with event queue
reimplementing flume sink using TSDB directrly