data class SslConfig(val truststorePath: String = requiredConfigForKey("KAFKA_TRUSTSTORE_PATH"), val keystorePath: String = requiredConfigForKey("KAFKA_KEYSTORE_PATH"), val credstorePsw: String = requiredConfigForKey("KAFKA_CREDSTORE_PASSWORD"))(source)