in src/main/java/com/epam/digital/data/platform/starter/kafkaapi/config/KafkaConfig.java [109:118]
private Map<String, Object> createSslProperties() {
return Map.of(
CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, SECURITY_PROTOCOL,
SslConfigs.SSL_TRUSTSTORE_TYPE_CONFIG, CERTIFICATES_TYPE,
SslConfigs.SSL_KEYSTORE_TYPE_CONFIG, CERTIFICATES_TYPE,
SSL_TRUSTSTORE_CERTIFICATES, kafkaProperties.getSsl().getTruststoreCertificate(),
SSL_KEYSTORE_CERTIFICATE_CHAIN, kafkaProperties.getSsl().getKeystoreCertificate(),
SSL_KEYSTORE_KEY, kafkaProperties.getSsl().getKeystoreKey()
);
}