curator.blockUntilConnected();
} catch (InterruptedException e) {
log.error("error while setting curator framework :",e);
curator.blockUntilConnected();
} catch (InterruptedException e) {
log.error("error while setting curator framework :",e);
Thread.sleep(consumerHandoverWaitMs);
} catch (InterruptedException e) {
log.error("InterruptedException in dropTimedOutConsumer",e);
Thread.sleep(consumerHandoverWaitMs);
} catch (InterruptedException e) {
log.error("InterruptedException in dropTimedOutConsumer",e);