in kafka/configfile.go [159:172]
func loadConfigFile(filepath string) (configProperties, error) {
var config configProperties
data, err := os.ReadFile(filepath)
if err != nil {
return config, fmt.Errorf("error reading kafka config file: %w", err)
}
if err := yaml.Unmarshal(data, &config); err != nil {
return config, fmt.Errorf("error parsing kafka config file %q: %w", filepath, err)
}
if err := config.SASL.finalize(); err != nil {
return configProperties{}, err
}
return config, nil
}