ConcurrentKafkaListenerContainerFactory concurrentKafkaListenerContainerFactory()

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

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

      ConcurrentKafkaListenerContainerFactory<String, O> concurrentKafkaListenerContainerFactory(
          ConsumerFactory<String, O> consumerFactory,
          Optional<KafkaTemplate<String, O>> kafkaTemplate,
          CommonErrorHandler errorHandler) {
    ConcurrentKafkaListenerContainerFactory<String, O> factory =
        new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory);
    factory.getContainerProperties().setMissingTopicsFatal(false);
    kafkaTemplate.ifPresent(factory::setReplyTemplate);
    factory.setCommonErrorHandler(errorHandler);
    return factory;
  }