Add test for realtime queue data buildup on sink clusters