public Map consumerConfigs()

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

• 16 lines of code
• 2 McCabe index (conditional complexity)

  public Map<String, Object> consumerConfigs() {
    Map<String, Object> props = new HashMap<>();
    props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaProperties.getBootstrap());
    props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
    props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
    props.put(JsonDeserializer.TRUSTED_PACKAGES,
        String.join(",", kafkaProperties.getTrustedPackages()));
    props.put(ConsumerConfig.GROUP_ID_CONFIG, kafkaProperties.getGroupId());
    props.put(ConsumerConfig.ALLOW_AUTO_CREATE_TOPICS_CONFIG, false);
    props.put(ConsumerConfig.RETRY_BACKOFF_MS_CONFIG, Duration.ofSeconds(10).toMillis());

    if (kafkaProperties.getSsl().isEnabled()) {
      props.putAll(createSslProperties());
    }
    props.putAll(kafkaProperties.getConsumerConfigs());
    return props;
  }