Reconnect to event stream if broken. Ensure some kind of offset for reconnect to not spam the instance to death.