Clean internal consumer on dataobserver.stop()