private Map producerConfigs()

in src/main/java/com/epam/digital/data/platform/starter/kafka/config/KafkaProducerConfig.java [67:77]

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

  private Map<String, Object> producerConfigs() {
    KafkaProducer producerProperties = kafkaProperties.getProducer();
    Map<String, Object> props = new HashMap<>();
    props.computeIfAbsent(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, v -> kafkaProperties.getBootstrap());
    props.computeIfAbsent(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, v -> producerProperties.getKeySerializer());
    props.computeIfAbsent(
            ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, v -> producerProperties.getValueSerializer());
    props.putAll(SslUtil.createSslConfigs(kafkaProperties.getSsl()));
    props.putAll(producerProperties.getCustomConfig());
    return props;
  }