in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerAttributeBindingProvider.cs [150:162]
private string GetValidFilePath(string location)
{
if (string.IsNullOrWhiteSpace(location))
{
return null;
}
var resolvedLocation = this.config.ResolveSecureSetting(nameResolver, location);
if (!AzureFunctionsFileHelper.TryGetValidFilePath(resolvedLocation, out var validPath))
{
throw new Exception($"{location} is not a valid file location");
}
return validPath;
}