-
- 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);
- }
- }