userstream now writing to ES in real-time