private Map auditProducerConfigs()

in src/main/java/com/epam/digital/data/platform/starter/audit/config/AuditKafkaConfig.java [57:67]

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

  private Map<String, Object> auditProducerConfigs() {
    Map<String, Object> props = new HashMap<>();
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, auditKafkaProperties.getBootstrap());
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class);
    props.put(AbstractKafkaSchemaSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, auditKafkaProperties.getSchemaRegistryUrl());
    if (auditKafkaProperties.getSsl().isEnabled()) {
      props.putAll(createSslProperties());
    }
    return props;
  }