public KafkaTemplate kafkaTemplate()

in src/it/java/com/epam/digital/data/platform/bphistory/persistence/BaseKafkaIT.java [69:79]

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

    public KafkaTemplate<String, Object> kafkaTemplate(KafkaProperties kafkaProperties) {
      Map<String, Object> producerProps =
          Map.of(
              ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,
              kafkaProperties.getBootstrap(),
              ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
              StringSerializer.class,
              ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
              JsonSerializer.class);
      return new KafkaTemplate<>(new DefaultKafkaProducerFactory<>(producerProps));
    }