ConcurrentKafkaListenerContainerFactory concurrentKafkaListenerContainerFactory()

in src/main/java/com/epam/digital/data/platform/starter/restapi/config/KafkaConfig.java [135:141]

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

  ConcurrentKafkaListenerContainerFactory<String, O> concurrentKafkaListenerContainerFactory(
      ConsumerFactory<String, O> cf) {
    ConcurrentKafkaListenerContainerFactory<String, O> factory =
        new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(cf);
    return factory;
  }