+ private void sleepAfterFailure() {
+ logger.warn("DMAAP message Consumer is put to Sleep for {} milliseconds", FETCHTIMEOUT);
+ try {
+ sleep.await(FETCHTIMEOUT, TimeUnit.MILLISECONDS);
+ } catch (InterruptedException e) {
+ logger.error("Failed to put the thread to sleep: {}", e);
+ }