public KafkaTemplate replyTemplate()

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

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

  public <O> KafkaTemplate<String, O> replyTemplate(
      ProducerFactory<String, O> pf, ConcurrentKafkaListenerContainerFactory<String, O> factory) {
    KafkaTemplate<String, O> kafkaTemplate = new KafkaTemplate<>(pf);
    factory.getContainerProperties().setMissingTopicsFatal(false);
    factory.setReplyTemplate(kafkaTemplate);
    factory.setErrorHandler(deadLetterErrorHandler(kafkaTemplate));
    return kafkaTemplate;
  }