private SeekToCurrentErrorHandler deadLetterErrorHandler()

in src/main/java/com/epam/digital/data/platform/starter/kafkaapi/config/KafkaConfig.java [145:153]

• 9 lines of code
• 1 McCabe index (conditional complexity)

  private SeekToCurrentErrorHandler deadLetterErrorHandler(
      KafkaOperations<String, ?> kafkaTemplate) {
    DeadLetterPublishingRecoverer recoverer = new DeadLetterPublishingRecoverer(kafkaTemplate);
    ErrorHandler errorHandler = kafkaProperties.getErrorHandler();
    ExponentialBackOff backOff = new ExponentialBackOff(errorHandler.getInitialInterval(),
        errorHandler.getMultiplier());
    backOff.setMaxElapsedTime(errorHandler.getMaxElapsedeTime());
    return new SeekToCurrentErrorHandler(recoverer, backOff);
  }