in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java [131:137]
private void sleepAfterError() {
try {
Thread.sleep(errorSleepMs);
} catch (InterruptedException e1) {
Thread.currentThread().interrupt();
}
}