in src/main/java/com/epam/digital/data/platform/starter/kafkaapi/config/KafkaConfig.java [64:72]
public Map<String, Object> producerConfigs() {
Map<String, Object> props = new HashMap<>();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaProperties.getBootstrap());
if (kafkaProperties.getSsl().isEnabled()) {
props.putAll(createSslProperties());
}
props.putAll(kafkaProperties.getProducerConfigs());
return props;
}