Invoke Subscriber.onError on broker failures