Add better error handling/retry policies around disconnections & rebalances

[anglinb]

I've yet to document the problem fully but the consumer stops every 5-12 hours for some reason. So would love some of the same retry primitives we have from effect like Effect.retry. I'm not sure exactly how we would achieve this but maybe some of the events emitted from on('... could trigger as errors which could then be caught as in the HttpRouter.