Need a Runnable because if not all sources are drained we add it zookeeper listener.