private Map consumerConfigs()

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

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

  private Map<String, Object> consumerConfigs() {
    KafkaConsumer consumerProperties = kafkaProperties.getConsumer();
    Map<String, Object> props = new HashMap<>();
    props.computeIfAbsent(
        ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, v -> kafkaProperties.getBootstrap());
    props.computeIfAbsent(
        ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, v -> consumerProperties.getKeyDeserializer());
    props.computeIfAbsent(
        ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
        v -> consumerProperties.getValueDeserializer());
    props.computeIfAbsent(
        JsonDeserializer.TRUSTED_PACKAGES,
        v -> String.join(",", consumerProperties.getTrustedPackages()));
    props.computeIfAbsent(ConsumerConfig.GROUP_ID_CONFIG, v -> consumerProperties.getGroupId());
    props.putAll(SslUtil.createSslConfigs(kafkaProperties.getSsl()));
    props.putAll(consumerProperties.getCustomConfig());
    return props;
  }