+ if (throwable instanceof Error) {
+ log.error("Unexpected error in event subscriber " + eventSubscriber + " for topic " + topic
+ + ", not trying to resubscribe.", throwable);
+ } else {
+ log.error("Unexpected exception in event subscriber " + eventSubscriber + " for topic " + topic
+ + ", resubscribing...", throwable);
+ addEventSubscriber(topic, eventSubscriber);
+ }