public CommonErrorHandler dlqDeadLetterErrorHandler()

in src/main/java/com/epam/digital/data/platform/starter/kafka/config/KafkaConsumerConfig.java [89:94]

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

  public CommonErrorHandler dlqDeadLetterErrorHandler(KafkaOperations<String, ?> kafkaTemplate) {
    DeadLetterPublishingRecoverer recoverer = new DeadLetterPublishingRecoverer(kafkaTemplate);
    ExponentialBackOff backOff =
        createExponentialBackOff(kafkaProperties.getConsumer().getErrorHandler());
    return new DefaultErrorHandler(recoverer, backOff);
  }